OfflineManager
StockSharp.Algo
离线消息处理执行.
实现: IOfflineManager
构造函数
OfflineManager
public OfflineManager(ILogReceiver logReceiver, Func<Message> createProcessSuspendedMessage, IOfflineManagerState state)offlineManager = OfflineManager(logReceiver, createProcessSuspendedMessage, state)离线消息处理执行.
- logReceiver
- 记录接收器。
- createProcessSuspendedMessage
- 创建消息, 恢复连接后恢复处理 。
- state
- 州库.
属性
MaxMessageCount
public int MaxMessageCount { get; set; }value = offlineManager.MaxMessageCount
offlineManager.MaxMessageCount = value最大消息队列数 。
方法
ProcessInMessage
public ValueTuple<Message[], Message[], bool> ProcessInMessage(Message message)result = offlineManager.ProcessInMessage(message)处理一个消息进入内置适配器。
- message
- 来电消息.
返回值: 处理结果为消息可转发并输出消息.
ProcessOutMessage
public ValueTuple<bool, Message[]> ProcessOutMessage(Message message)result = offlineManager.ProcessOutMessage(message)处理来自内置适配器的邮件 。
- message
- 传出消息.
返回值: 处理结果为转发消息和额外的输出消息.