OfflineMessageAdapter
StockSharp.Algo
The messages adapter keeping message until connection will be done.
Inherits: MessageAdapterWrapper
Constructors
OfflineMessageAdapter
public OfflineMessageAdapter(IMessageAdapter innerAdapter)
offlineMessageAdapter = OfflineMessageAdapter(innerAdapter)
Initializes a new instance of the OfflineMessageAdapter.
- innerAdapter
- Underlying adapter.
OfflineMessageAdapter
public OfflineMessageAdapter(IMessageAdapter innerAdapter, IOfflineManager manager)
offlineMessageAdapter = OfflineMessageAdapter(innerAdapter, manager)
Initializes a new instance of the OfflineMessageAdapter with a custom manager.
- innerAdapter
- Underlying adapter.
- manager
- Offline manager.
Properties
MaxMessageCount
public int MaxMessageCount { get; set; }
value = offlineMessageAdapter.MaxMessageCount
offlineMessageAdapter.MaxMessageCount = value
Max message queue count. The default value is 10000.
SendInBackFurther
protected override bool SendInBackFurther { get; }
value = offlineMessageAdapter.SendInBackFurther
Auto send BackMode messages to InnerAdapter.
Methods
Clone
public override IMessageAdapter Clone()
result = offlineMessageAdapter.Clone()
Create a copy of OfflineMessageAdapter.
Returns: Copy.
OnInnerAdapterNewOutMessageAsync
protected override ValueTask OnInnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)
result = offlineMessageAdapter.OnInnerAdapterNewOutMessageAsync(message, cancellationToken)
Process InnerAdapter output message.
- message
- The message.
- cancellationToken
- Cancellation token.
OnSendInMessageAsync
protected override ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)
result = offlineMessageAdapter.OnSendInMessageAsync(message, cancellationToken)
Send message.
- message
- Message.
- cancellationToken
- CancellationToken