OfflineMessageAdapter
StockSharp.Algo
信件适配器保存信件直到连接完成 。
构造函数
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
Auto send BackMode messages to InnerAdapter.
方法
Clone
public override IMessageAdapter Clone()
result = offlineMessageAdapter.Clone()
Create a copy of 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