StorageMessageAdapter

StorageMessageAdapter

public StorageMessageAdapter(IMessageAdapter innerAdapter, IStorageProcessor storageProcessor)

storageMessageAdapter = StorageMessageAdapter(innerAdapter, storageProcessor)

Adaptador de mensagem baseado em armazenamento.

innerAdapter

O adaptador, ao qual as mensagens serão dirigidas.

storageProcessor

Processador de armazenamento.

Clone

public override IMessageAdapter Clone()

result = storageMessageAdapter.Clone()

Criar uma cópia de StorageMessageAdapter.

Retorna: Entendido.

GetSupportedMarketDataTypesAsync

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

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

Seja suportado por tipos de mensagem adaptador.

securityId

SecurityId

from

Data de início para solicitação. Se , em seguida, todas as mensagens disponíveis serão devolvidos.

to

Data de fim para a solicitação. Se , então todas as mensagens disponíveis serão devolvidas.

Retorna: Suportado por tipos de dados de mercado adaptador.

OnSendInMessageAsync

protected override ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)

result = storageMessageAdapter.OnSendInMessageAsync(message, cancellationToken)

Enviar mensagem.

message

Message.

cancellationToken

CancellationToken