BufferMessageAdapter

BufferMessageAdapter

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

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

Адаптер буферизованных сообщений.

innerAdapter

Базовый адаптер.

settings

Настройки хранилища.

buffer

Буфер хранения.

snapshotRegistry

Реестр хранилища снимков.

Buffer

public IStorageBuffer Buffer { get; }

value = bufferMessageAdapter.Buffer

Буфер хранения.

Settings

public StorageCoreSettings Settings { get; }

value = bufferMessageAdapter.Settings

Настройки хранилища.

SnapshotRegistry

public ISnapshotRegistry SnapshotRegistry { get; }

value = bufferMessageAdapter.SnapshotRegistry

Реестр хранилища снимков.

Clone

public override IMessageAdapter Clone()

result = bufferMessageAdapter.Clone()

Создайте копию BufferMessageAdapter.

Возвращает: Копия.

Dispose

public override void Dispose()

bufferMessageAdapter.Dispose()

Удаляет элементы в пуле, реализующие IDisposable.

OnInnerAdapterNewOutMessageAsync

protected override ValueTask OnInnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)

result = bufferMessageAdapter.OnInnerAdapterNewOutMessageAsync(message, cancellationToken)

Обработать выходное сообщение InnerAdapter.

message

Сообщение.

cancellationToken

Токен отмены.

OnSendInMessageAsync

protected override ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)

result = bufferMessageAdapter.OnSendInMessageAsync(message, cancellationToken)

Отправить сообщение.

message

Message.

cancellationToken

CancellationToken

ProcessOrderStatusAsync

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

result = bufferMessageAdapter.ProcessOrderStatusAsync(message, cancellationToken)

Процесс OrderStatusMessage.

message

Сообщение с запросом текущих зарегистрированных ордеров и сделок.

cancellationToken

CancellationToken

Возвращает: Сообщение с запросом текущих зарегистрированных ордеров и сделок.

Reset

private void Reset()

bufferMessageAdapter.Reset()

Чтобы сбросить состояние.

StartStorageTimer

private void StartStorageTimer()

bufferMessageAdapter.StartStorageTimer()

Запустите поток автосохранения хранилища.