ConnectorSubscriptionManager

ConnectorSubscriptionManager

public ConnectorSubscriptionManager(ILogReceiver logReceiver, IdGenerator transactionIdGenerator, bool sendUnsubscribeWhenDisconnected)

connectorSubscriptionManager = ConnectorSubscriptionManager(logReceiver, transactionIdGenerator, sendUnsubscribeWhenDisconnected)

Управляет подписками и их жизненным циклом.

logReceiver

Приемник журналов.

transactionIdGenerator

Генератор идентификаторов транзакций.

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

Восстановить подписку на Reconnect.

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

Отправляйте подписки на Connect.

TransactionIdGenerator

public IdGenerator TransactionIdGenerator { get; set; }

value = connectorSubscriptionManager.TransactionIdGenerator
connectorSubscriptionManager.TransactionIdGenerator = value

Генератор идентификаторов транзакций.

ClearCache

public void ClearCache()

connectorSubscriptionManager.ClearCache()

Ясное внутреннее состояние.

GetSubscribers

public IEnumerable<SecurityId> GetSubscribers(DataType dataType)

result = connectorSubscriptionManager.GetSubscribers(dataType)

Получите финансовые инструменты с активными подписками на указанный тип данных.

dataType

Тип данных.

Возвращает: финансовые инструменты с активной подпиской.

GetSubscriptions

public IEnumerable<Subscription> GetSubscriptions(ISubscriptionIdMessage message)

result = connectorSubscriptionManager.GetSubscriptions(message)

Разрешить подписки на указанное сообщение.

message

Сообщение с идентификаторами подписок.

Возвращает: Подписки.

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

Идентификатор подписки.

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

Послание свечи.

Возвращает: Обновлены подписки со свечами.