ConnectorSubscriptionManager
StockSharp.Algo
サブスクリプションとライフサイクルの管理
コンストラクター
ConnectorSubscriptionManager
public ConnectorSubscriptionManager(ILogReceiver logReceiver, IdGenerator transactionIdGenerator, bool sendUnsubscribeWhenDisconnected)connectorSubscriptionManager = ConnectorSubscriptionManager(logReceiver, transactionIdGenerator, sendUnsubscribeWhenDisconnected)サブスクリプションとライフサイクルの管理
- logReceiver
- ログ受信機。
- transactionIdGenerator
- トランザクションIDジェネレータ。
- sendUnsubscribeWhenDisconnected
- 接続解除時に未登録のリクエストを送るかどうかを指示します。
プロパティ
ConnectionState
public ConnectionStates ConnectionState { get; set; }value = connectorSubscriptionManager.ConnectionState
connectorSubscriptionManager.ConnectionState = value現在の接続状態。
IsRestoreSubscriptionOnNormalReconnect
public bool IsRestoreSubscriptionOnNormalReconnect { get; set; }value = connectorSubscriptionManager.IsRestoreSubscriptionOnNormalReconnect
connectorSubscriptionManager.IsRestoreSubscriptionOnNormalReconnect = value再接続でサブスクリプションを復元します。
SendUnsubscribeWhenDisconnected
public bool SendUnsubscribeWhenDisconnected { get; }value = connectorSubscriptionManager.SendUnsubscribeWhenDisconnected接続解除時に未登録のリクエストを送るかどうかを指示します。
Subscriptions
public IEnumerable<Subscription> Subscriptions { get; }value = connectorSubscriptionManager.Subscriptions現在のサブスクリプションのスナップショット。
SubscriptionsOnConnect
public CachedSynchronizedSet<Subscription> SubscriptionsOnConnect { get; }value = connectorSubscriptionManager.SubscriptionsOnConnectサブスクリプションをコネクトに送信する。
TransactionIdGenerator
public IdGenerator TransactionIdGenerator { get; set; }value = connectorSubscriptionManager.TransactionIdGenerator
connectorSubscriptionManager.TransactionIdGenerator = valueトランザクションIDジェネレータ。
メソッド
GetSubscribers
public IEnumerable<SecurityId> GetSubscribers(DataType dataType)result = connectorSubscriptionManager.GetSubscribers(dataType)指定されたデータ型に有効なサブスクリプションを持つ金融商品を取得します。
- dataType
- データ型。
戻り値: 有効なサブスクリプションを持つ金融商品。
GetSubscriptions
public IEnumerable<Subscription> GetSubscriptions(ISubscriptionIdMessage message)result = connectorSubscriptionManager.GetSubscriptions(message)指定したメッセージのサブスクリプションを解決します。
- message
- サブスクリプションIDでメッセージ。
戻り値: サブスクリプション。
HandleConnected
public Actions HandleConnected(Subscription[] subscriptions)result = connectorSubscriptionManager.HandleConnected(subscriptions)接続イベントを処理し、必要に応じてサブスクリプションを復元します。
- subscriptions
- デフォルトサブスクリプション。
戻り値: 応募するアクション
HandleConnected
public Actions HandleConnected(Func<Subscription, bool> subscriptionFilter)result = connectorSubscriptionManager.HandleConnected(subscriptionFilter)接続イベントを処理し、必要に応じてサブスクリプションを復元します。
- subscriptionFilter
- フィルタSubscriptionsOnConnect@
戻り値: 応募するアクション
ProcessLookupResponse``1
public IEnumerable<Subscription> ProcessLookupResponse<T>(ISubscriptionIdMessage message, T item)result = connectorSubscriptionManager.ProcessLookupResponse(message, item)ラップアップ応答項目を処理する。
- message
- メッセージを検索します。
- item
- アイテムを探します。
戻り値: アイテムを受け取ったサブスクリプション。
ProcessResponse
public Subscription ProcessResponse(SubscriptionResponseMessage response, ISubscriptionMessage originalMsg, bool unexpectedCancelled, Object[] items)result = connectorSubscriptionManager.ProcessResponse(response, originalMsg, unexpectedCancelled, items)サブスクリプションの応答メッセージを処理する。
- response
- 応答メッセージ。
- originalMsg
- オリジナルサブスクリプション。リクエスト
- unexpectedCancelled
- エラーにより、アクティブなサブスクリプションがキャンセルされたことを示します。
- items
- 収集したルックアップアイテム。
戻り値: サブスクリプションインスタンス。
ProcessSubscriptionFinishedMessage
public Subscription ProcessSubscriptionFinishedMessage(SubscriptionFinishedMessage message, Object[] items)result = connectorSubscriptionManager.ProcessSubscriptionFinishedMessage(message, items)サブスクリプションの終了メッセージを処理する。
- message
- 完了メッセージ。
- items
- 収集したルックアップアイテム。
戻り値: サブスクリプションインスタンス。
ProcessSubscriptionOnlineMessage
public Subscription ProcessSubscriptionOnlineMessage(SubscriptionOnlineMessage message, Object[] items)result = connectorSubscriptionManager.ProcessSubscriptionOnlineMessage(message, items)サブスクリプションオンラインメッセージの処理
- message
- オンラインメッセージ
- items
- 収集したルックアップアイテム。
戻り値: サブスクリプションインスタンス。
Subscribe
public Actions Subscribe(Subscription subscription, bool isAllExtension)result = connectorSubscriptionManager.Subscribe(subscription, isAllExtension)サブスクリプションリクエストを送信します。
- subscription
- サブスクリプション。
- isAllExtension
- 「全ての金融商品」の拡張子を示す。
戻り値: 応募するアクション
TryGetSubscription
public Subscription TryGetSubscription(long id, bool ignoreAll, bool remove, DateTime? time)result = connectorSubscriptionManager.TryGetSubscription(id, ignoreAll, remove, time)id でサブスクリプションを入手してください。
- id
- サブスクリプションID。
- ignoreAll
- 「全ての金融商品」マッピングを無視します。
- remove
- キャッシュから削除します。
- time
- 任意サーバー時間。
戻り値: サブスクリプションまたは.
UnSubscribe
public Actions UnSubscribe(Subscription subscription)result = connectorSubscriptionManager.UnSubscribe(subscription)退会リクエストを送信します。
- subscription
- サブスクリプション。
戻り値: 応募するアクション
UnSubscribeAll
public Actions UnSubscribeAll()result = connectorSubscriptionManager.UnSubscribeAll()アクティブなサブスクリプションを全て登録解除します。
戻り値: 応募するアクション
UpdateCandles
public IEnumerable<ValueTuple<Subscription, ICandleMessage>> UpdateCandles(CandleMessage message)result = connectorSubscriptionManager.UpdateCandles(message)サブスクリプションのキャンドルを更新し、更新された結果を返します。
- message
- キャンドルメッセージ。
戻り値: サブスクリプションをキャンドルで更新しました。