BufferMessageAdapter

BufferMessageAdapter

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

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

Adaptador de mensajes amortiguados.

innerAdapter

Adaptador subyacente.

settings

Ajustes de almacenamiento.

buffer

Buffer de almacenamiento.

snapshotRegistry

Registro de almacenamiento de instantáneas.

Buffer

public IStorageBuffer Buffer { get; }

value = bufferMessageAdapter.Buffer

Buffer de almacenamiento.

Settings

public StorageCoreSettings Settings { get; }

value = bufferMessageAdapter.Settings

Ajustes de almacenamiento.

SnapshotRegistry

public ISnapshotRegistry SnapshotRegistry { get; }

value = bufferMessageAdapter.SnapshotRegistry

Registro de almacenamiento de instantáneas.

Clone

public override IMessageAdapter Clone()

result = bufferMessageAdapter.Clone()

Crear una copia de BufferMessageAdapter.

Devuelve: Copiado.

Dispose

public override void Dispose()

bufferMessageAdapter.Dispose()

Desembolsos de elementos en la piscina que implementan IDesechable.

OnInnerAdapterNewOutMessageAsync

protected override ValueTask OnInnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)

result = bufferMessageAdapter.OnInnerAdapterNewOutMessageAsync(message, cancellationToken)

Proceso InnerAdapter@ mensaje de salida.

message

El mensaje.

cancellationToken

Cancelación token.

OnSendInMessageAsync

protected override ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)

result = bufferMessageAdapter.OnSendInMessageAsync(message, cancellationToken)

Envía mensaje.

message

Message.

cancellationToken

CancellationToken

ProcessOrderStatusAsync

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

result = bufferMessageAdapter.ProcessOrderStatusAsync(message, cancellationToken)

Proceso OrderStatusMessage@.

message

Un mensaje solicitando pedidos y oficios registrados.

cancellationToken

CancellationToken

Devuelve: Un mensaje solicitando pedidos y oficios registrados.

Reset

private void Reset()

bufferMessageAdapter.Reset()

Para restablecer el estado.

StartStorageTimer

private void StartStorageTimer()

bufferMessageAdapter.StartStorageTimer()

Comience el almacenamiento de hilo auto-salvado.