BufferMessageAdapter
StockSharp.Algo.Storages
Buffered message adapter.
Inherits: MessageAdapterWrapper
Constructors
BufferMessageAdapter(IMessageAdapter, StorageCoreSettings, IStorageBuffer, ISnapshotRegistry)
Buffered message adapter.
- innerAdapter
- Underlying adapter.
- settings
- Storage settings.
- buffer
- Storage buffer.
- snapshotRegistry
- Snapshot storage registry.
Properties
Buffer : IStorageBuffer
Storage buffer.
Settings : StorageCoreSettings
Storage settings.
SnapshotRegistry : ISnapshotRegistry
Snapshot storage registry.
Methods
Dispose()
Disposes of items in the pool that implement IDisposable.
OnInnerAdapterNewOutMessageAsync(Message, CancellationToken) : ValueTask
Process InnerAdapter output message.
- message
- The message.
- cancellationToken
- Cancellation token.
OnSendInMessageAsync(Message, CancellationToken) : ValueTask
Send message.
ProcessOrderStatusAsync(OrderStatusMessage, CancellationToken) : ValueTask<OrderStatusMessage>
Process OrderStatusMessage.
- message
- A message requesting current registered orders and trades.
- cancellationToken
- CancellationToken
Returns: A message requesting current registered orders and trades.
Reset()
To reset the state.
StartStorageTimer()
Start storage auto-save thread.