SubscriptionManager — StockSharp 文档

构造函数

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

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

订阅消息处理执行.

logReceiver: 记录接收器。
transactionIdGenerator: 交易ID生成器。
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: 传出消息.

返回值: 处理结果为转发消息和额外的输出消息.