ConnectorSubscriptionManager
Manages subscriptions and their lifecycle.
构造函数
ConnectorSubscriptionManager(ILogReceiver, IdGenerator, bool)
Manages subscriptions and their lifecycle.
- logReceiver
- Log receiver.
- transactionIdGenerator
- Transaction id generator.
- sendUnsubscribeWhenDisconnected
- Indicates whether to send unsubscribe requests while disconnected.
属性
ConnectionState : ConnectionStates
Current connection state.
IsRestoreSubscriptionOnNormalReconnect : bool
Restore subscription on reconnect.
SendUnsubscribeWhenDisconnected : bool
Indicates whether to send unsubscribe requests while disconnected.
Subscriptions : IEnumerable<Subscription>
Current subscriptions snapshot.
SubscriptionsOnConnect : CachedSynchronizedSet<Subscription>
Send subscriptions on connect.
TransactionIdGenerator : IdGenerator
Transaction id generator.
方法
ClearCache()
Clear internal state.
GetSubscribers(DataType) : IEnumerable<SecurityId>
Get securities that have active subscriptions for the specified data type.
- dataType
- Data type.
返回值: Securities with active subscriptions.
GetSubscriptions(ISubscriptionIdMessage) : IEnumerable<Subscription>
Resolve subscriptions for the specified message.
- message
- Message with subscription ids.
返回值: Subscriptions.
HandleConnected(Subscription[]) : Actions
Handle connection event and restore subscriptions as needed.
- subscriptions
- Default subscriptions.
返回值: Actions to apply.
HandleConnected(Func<Subscription, bool>) : Actions
Handle connection event and restore subscriptions as needed.
- subscriptionFilter
- Filter for SubscriptionsOnConnect.
返回值: Actions to apply.
ProcessLookupResponse``1(ISubscriptionIdMessage, T)
Process a lookup response item.
- message
- Lookup message.
- item
- Lookup item.
返回值: Subscriptions that received the item.
ProcessResponse(SubscriptionResponseMessage, ISubscriptionMessage, bool, Object[]) : Subscription
Process a subscription response message.
- response
- Response message.
- originalMsg
- Original subscription request.
- unexpectedCancelled
- Indicates that active subscription was canceled due to error.
- items
- Collected lookup items.
返回值: Subscription instance.
ProcessSubscriptionFinishedMessage(SubscriptionFinishedMessage, Object[]) : Subscription
Process a subscription finished message.
- message
- Finished message.
- items
- Collected lookup items.
返回值: Subscription instance.
ProcessSubscriptionOnlineMessage(SubscriptionOnlineMessage, Object[]) : Subscription
Process a subscription online message.
- message
- Online message.
- items
- Collected lookup items.
返回值: Subscription instance.
Subscribe(Subscription, bool) : Actions
Send a subscription request.
- subscription
- Subscription.
- isAllExtension
- Indicates "all securities" extension.
返回值: Actions to apply.
TryGetSubscription(long, bool, bool, DateTime?) : Subscription
Try get subscription by id.
- id
- Subscription id.
- ignoreAll
- Ignore "all securities" mapping.
- remove
- Remove from cache.
- time
- Optional server time.
返回值: Subscription or .
UnSubscribe(Subscription) : Actions
Send an unsubscribe request.
- subscription
- Subscription.
返回值: Actions to apply.
UpdateCandles(CandleMessage) : IEnumerable<ValueTuple<Subscription, ICandleMessage>>
Update candles for subscriptions and return updated results.
- message
- Candle message.
返回值: Updated subscriptions with candles.