SubscriptionManager

StockSharp.Algo

Реализация обработки сообщений о подписке.

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

public SubscriptionManager(ILogReceiver logReceiver, IdGenerator transactionIdGenerator, Func<Message> createProcessSuspendedMessage, ISubscriptionManagerState state)

subscriptionManager = SubscriptionManager(logReceiver, transactionIdGenerator, createProcessSuspendedMessage, state)

Реализация обработки сообщений о подписке.

logReceiver: Приемник журналов.
transactionIdGenerator: Генератор идентификаторов транзакций.
createProcessSuspendedMessage: Создайте сообщение, которое возобновляет обработку после постановки в очередь пересопоставленных подписок.
state: Государственное хранилище.

Свойства

State

public ISubscriptionManagerState State { get; }

value = subscriptionManager.State

Государственное хранилище.

Методы

ProcessInMessage

public ValueTuple<Message[], Message[]> ProcessInMessage(Message message)

result = subscriptionManager.ProcessInMessage(message)

Обработать сообщение, поступающее во внутренний адаптер.

message: Входящее сообщение.

Возвращает: Результат обработки с сообщениями для пересылки и вывода сообщений.

ProcessOutMessage

public ValueTuple<Message, Message[]> ProcessOutMessage(Message message)

result = subscriptionManager.ProcessOutMessage(message)

Обработать сообщение, поступающее от внутреннего адаптера.

message: Исходящее сообщение.

Возвращает: Результат обработки с пересылаемым сообщением и дополнительными выходными сообщениями.