BufferMessageAdapter

BufferMessageAdapter

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

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

Buffered message adapter.

innerAdapter

Underlying adapter.

settings

Storage settings.

buffer

Storage buffer.

snapshotRegistry

Snapshot storage registry.

Buffer

public IStorageBuffer Buffer { get; }

value = bufferMessageAdapter.Buffer

Storage buffer.

Settings

public StorageCoreSettings Settings { get; }

value = bufferMessageAdapter.Settings

Storage settings.

SnapshotRegistry

public ISnapshotRegistry SnapshotRegistry { get; }

value = bufferMessageAdapter.SnapshotRegistry

Snapshot storage registry.

Clone

public override IMessageAdapter Clone()

result = bufferMessageAdapter.Clone()

Create a copy of BufferMessageAdapter.

Returns: Copy.

Dispose

public override void Dispose()

bufferMessageAdapter.Dispose()

Disposes of items in the pool that implement IDisposable.

OnInnerAdapterNewOutMessageAsync

protected override ValueTask OnInnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)

result = bufferMessageAdapter.OnInnerAdapterNewOutMessageAsync(message, cancellationToken)

Process InnerAdapter output message.

message

The message.

cancellationToken

Cancellation token.

OnSendInMessageAsync

protected override ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)

result = bufferMessageAdapter.OnSendInMessageAsync(message, cancellationToken)

Send message.

message

Message.

cancellationToken

CancellationToken

ProcessOrderStatusAsync

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

result = bufferMessageAdapter.ProcessOrderStatusAsync(message, cancellationToken)

Process OrderStatusMessage.

message

A message requesting current registered orders and trades.

cancellationToken

CancellationToken

Returns: A message requesting current registered orders and trades.

Reset

private void Reset()

bufferMessageAdapter.Reset()

To reset the state.

StartStorageTimer

private void StartStorageTimer()

bufferMessageAdapter.StartStorageTimer()

Start storage auto-save thread.