StorageMessageAdapter

StorageMessageAdapter

public StorageMessageAdapter(IMessageAdapter innerAdapter, IStorageProcessor storageProcessor)

storageMessageAdapter = StorageMessageAdapter(innerAdapter, storageProcessor)

Storage based message adapter.

innerAdapter

The adapter, to which messages will be directed.

storageProcessor

Storage processor.

Clone

public override IMessageAdapter Clone()

result = storageMessageAdapter.Clone()

Create a copy of StorageMessageAdapter.

Returns: Copy.

GetSupportedMarketDataTypesAsync

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

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

Get supported by adapter message types.

securityId

SecurityId

from

Start date for request. If , then all available messages will be returned.

to

End date for request. If , then all available messages will be returned.

Returns: Supported by adapter market data types.

OnSendInMessageAsync

protected override ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)

result = storageMessageAdapter.OnSendInMessageAsync(message, cancellationToken)

Send message.

message

Message.

cancellationToken

CancellationToken