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

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