OfflineMessageAdapter

StockSharp.Algo

Адаптер сообщений сохраняет сообщение до тех пор, пока не будет установлено соединение.

Наследует: MessageAdapterWrapper

Конструкторы

OfflineMessageAdapter
public OfflineMessageAdapter(IMessageAdapter innerAdapter)
offlineMessageAdapter = OfflineMessageAdapter(innerAdapter)

Инициализирует новый экземпляр OfflineMessageAdapter.

innerAdapter
Базовый адаптер.
OfflineMessageAdapter
public OfflineMessageAdapter(IMessageAdapter innerAdapter, IOfflineManager manager)
offlineMessageAdapter = OfflineMessageAdapter(innerAdapter, manager)

Инициализирует новый экземпляр OfflineMessageAdapter с помощью специального менеджера.

innerAdapter
Базовый адаптер.
manager
Оффлайн-менеджер.

Свойства

MaxMessageCount
public int MaxMessageCount { get; set; }
value = offlineMessageAdapter.MaxMessageCount
offlineMessageAdapter.MaxMessageCount = value

Количество очередей сообщений Макса. Значение по умолчанию 10000.

SendInBackFurther
protected override bool SendInBackFurther { get; }
value = offlineMessageAdapter.SendInBackFurther

Автоотправляйте сообщения BackMode на InnerAdapter.

Методы

Clone
public override IMessageAdapter Clone()
result = offlineMessageAdapter.Clone()

Создайте копию OfflineMessageAdapter.

Возвращает: Копия.

OnInnerAdapterNewOutMessageAsync
protected override ValueTask OnInnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)
result = offlineMessageAdapter.OnInnerAdapterNewOutMessageAsync(message, cancellationToken)

Обработать выходное сообщение InnerAdapter.

message
Сообщение.
cancellationToken
Токен отмены.
OnSendInMessageAsync
protected override ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)
result = offlineMessageAdapter.OnSendInMessageAsync(message, cancellationToken)

Отправить сообщение.

message
Message.
cancellationToken
CancellationToken