BufferMessageAdapter

BufferMessageAdapter

public BufferMessageAdapter(IMessageAdapter innerAdapter, StorageCoreSettings settings, IStorageBuffer buffer, ISnapshotRegistry snapshotRegistry)

bufferMessageAdapter = BufferMessageAdapter(innerAdapter, settings, buffer, snapshotRegistry)

Buffered Message Adapter.

innerAdapter

Unterliegender Adapter.

settings

Speichereinstellungen.

buffer

Speicherpuffer.

snapshotRegistry

Snapshot Storage Registry.

Buffer

public IStorageBuffer Buffer { get; }

value = bufferMessageAdapter.Buffer

Speicherpuffer.

Settings

public StorageCoreSettings Settings { get; }

value = bufferMessageAdapter.Settings

Speichereinstellungen.

SnapshotRegistry

public ISnapshotRegistry SnapshotRegistry { get; }

value = bufferMessageAdapter.SnapshotRegistry

Snapshot Storage Registry.

Clone

public override IMessageAdapter Clone()

result = bufferMessageAdapter.Clone()

Erstellen Sie eine Kopie von BufferMessageAdapter.

Rückgabe: Kopie.

Dispose

public override void Dispose()

bufferMessageAdapter.Dispose()

Entsorgt Elemente im Pool, die IDisposable implementieren.

OnInnerAdapterNewOutMessageAsync

protected override ValueTask OnInnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)

result = bufferMessageAdapter.OnInnerAdapterNewOutMessageAsync(message, cancellationToken)

Prozess InnerAdapter Ausgabenachricht.

message

Die Botschaft.

cancellationToken

Löschungszeichen.

OnSendInMessageAsync

protected override ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)

result = bufferMessageAdapter.OnSendInMessageAsync(message, cancellationToken)

Senden Sie eine Nachricht.

message

Message.

cancellationToken

CancellationToken

ProcessOrderStatusAsync

private ValueTask<OrderStatusMessage> ProcessOrderStatusAsync(OrderStatusMessage message, CancellationToken cancellationToken)

result = bufferMessageAdapter.ProcessOrderStatusAsync(message, cancellationToken)

Prozess OrderStatusMessage.

message

Eine Nachricht, die aktuelle registrierte Aufträge und Trades anfordert.

cancellationToken

CancellationToken

Rückgabe: Eine Nachricht, die aktuelle registrierte Aufträge und Trades anfordert.

Reset

private void Reset()

bufferMessageAdapter.Reset()

Um den Staat zurückzusetzen.

StartStorageTimer

private void StartStorageTimer()

bufferMessageAdapter.StartStorageTimer()

Starten Sie den automatischen Speicher-Thread.