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