BufferMessageAdapter

BufferMessageAdapter

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

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

Adaptador de mensagens com buffer.

innerAdapter

Adaptador subjacente.

settings

Configuração do armazenamento.

buffer

Tampão de armazenamento.

snapshotRegistry

Registo de armazenamento de instantâneos.

Buffer

public IStorageBuffer Buffer { get; }

value = bufferMessageAdapter.Buffer

Tampão de armazenamento.

Settings

public StorageCoreSettings Settings { get; }

value = bufferMessageAdapter.Settings

Configuração do armazenamento.

SnapshotRegistry

public ISnapshotRegistry SnapshotRegistry { get; }

value = bufferMessageAdapter.SnapshotRegistry

Registo de armazenamento de instantâneos.

Clone

public override IMessageAdapter Clone()

result = bufferMessageAdapter.Clone()

Criar uma cópia de BufferMessageAdapter.

Retorna: Entendido.

Dispose

public override void Dispose()

bufferMessageAdapter.Dispose()

Elimina os itens na piscina que implementam IDesposable.

OnInnerAdapterNewOutMessageAsync

protected override ValueTask OnInnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)

result = bufferMessageAdapter.OnInnerAdapterNewOutMessageAsync(message, cancellationToken)

Processo InnerAdapter output message.

message

A mensagem.

cancellationToken

Inscrição de cancelamento.

OnSendInMessageAsync

protected override ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)

result = bufferMessageAdapter.OnSendInMessageAsync(message, cancellationToken)

Enviar mensagem.

message

Message.

cancellationToken

CancellationToken

ProcessOrderStatusAsync

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

result = bufferMessageAdapter.ProcessOrderStatusAsync(message, cancellationToken)

Processo OrderStatusMessage.

message

Uma mensagem solicitando ordens e transações registradas atuais.

cancellationToken

CancellationToken

Retorna: Uma mensagem solicitando ordens e transações registradas atuais.

Reset

private void Reset()

bufferMessageAdapter.Reset()

Para reiniciar o estado.

StartStorageTimer

private void StartStorageTimer()

bufferMessageAdapter.StartStorageTimer()

Iniciar armazenamento auto-salvar thread.