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