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()

使い捨て可能を実装するプール内のアイテムの処分。

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)

担当: 佐藤 浩

message

登録された注文や取引をリクエストするメッセージのリクエスト。

cancellationToken

担当: 佐藤 宏

戻り値: 登録された注文や取引をリクエストするメッセージのリクエスト。

Reset

private void Reset()

bufferMessageAdapter.Reset()

状態をリセットする。

StartStorageTimer

private void StartStorageTimer()

bufferMessageAdapter.StartStorageTimer()

ストレージの自動保存スレッドを開始します。