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
- メッセージを発信する。
戻り値: 転送メッセージと出力メッセージの余分な処理結果。