StorageMessageAdapter

StorageMessageAdapter

public StorageMessageAdapter(IMessageAdapter innerAdapter, IStorageProcessor storageProcessor)

storageMessageAdapter = StorageMessageAdapter(innerAdapter, storageProcessor)

Adaptador de mensaje basado en almacenamiento.

innerAdapter

El adaptador, al que se dirigirán los mensajes.

storageProcessor

Procesador de almacenamiento.

CloneAsync

public override ValueTask<IMessageAdapter> CloneAsync(CancellationToken cancellationToken)

result = storageMessageAdapter.CloneAsync(cancellationToken)

Create a copy of StorageMessageAdapter.

cancellationToken

CancellationToken

Devuelve: Copy.

GetSupportedMarketDataTypesAsync

public override IAsyncEnumerable<DataType> GetSupportedMarketDataTypesAsync(SecurityId securityId, DateTime? from, DateTime? to)

result = storageMessageAdapter.GetSupportedMarketDataTypesAsync(securityId, from, to)

Consiga soporte por tipos de mensaje de adaptador.

securityId

SecurityId

from

Fecha de inicio para solicitar. Si , entonces todos los mensajes disponibles serán devueltos.

to

Fecha final para solicitar. Si , entonces todos los mensajes disponibles serán devueltos.

Devuelve: Apoyado por tipos de datos del mercado de adaptadores.

OnInnerAdapterNewOutMessageAsync

protected override ValueTask OnInnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)

result = storageMessageAdapter.OnInnerAdapterNewOutMessageAsync(message, cancellationToken)

Process InnerAdapter output message.

message

The message.

cancellationToken

Cancellation token.

OnSendInMessageAsync

protected override ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)

result = storageMessageAdapter.OnSendInMessageAsync(message, cancellationToken)

Envía mensaje.

message

Message.

cancellationToken

CancellationToken