ConnectorSubscriptionManager

ConnectorSubscriptionManager

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

connectorSubscriptionManager = ConnectorSubscriptionManager(logReceiver, transactionIdGenerator, sendUnsubscribeWhenDisconnected)

Gestiona suscripciones y su ciclo de vida.

logReceiver

Receptor de registro.

transactionIdGenerator

Generador de identificación de transacciones.

sendUnsubscribeWhenDisconnected

Indica si enviar solicitudes de cancelación de suscripción se desconectan.

ConnectionState

public ConnectionStates ConnectionState { get; set; }

value = connectorSubscriptionManager.ConnectionState
connectorSubscriptionManager.ConnectionState = value

Estado de conexión actual.

IsRestoreSubscriptionOnNormalReconnect

public bool IsRestoreSubscriptionOnNormalReconnect { get; set; }

value = connectorSubscriptionManager.IsRestoreSubscriptionOnNormalReconnect
connectorSubscriptionManager.IsRestoreSubscriptionOnNormalReconnect = value

Restaurar la suscripción en la reconexión.

SendUnsubscribeWhenDisconnected

public bool SendUnsubscribeWhenDisconnected { get; }

value = connectorSubscriptionManager.SendUnsubscribeWhenDisconnected

Indica si enviar solicitudes de cancelación de suscripción se desconectan.

Subscriptions

public IEnumerable<Subscription> Subscriptions { get; }

value = connectorSubscriptionManager.Subscriptions

Actual suscripciones instantáneas.

SubscriptionsOnConnect

public CachedSynchronizedSet<Subscription> SubscriptionsOnConnect { get; }

value = connectorSubscriptionManager.SubscriptionsOnConnect

Envía suscripciones en conexión.

TransactionIdGenerator

public IdGenerator TransactionIdGenerator { get; set; }

value = connectorSubscriptionManager.TransactionIdGenerator
connectorSubscriptionManager.TransactionIdGenerator = value

Generador de identificación de transacciones.

ClearCache

public void ClearCache()

connectorSubscriptionManager.ClearCache()

Estado interno claro.

GetSubscribers

public IEnumerable<SecurityId> GetSubscribers(DataType dataType)

result = connectorSubscriptionManager.GetSubscribers(dataType)

Obtenga instrumentos financieros que tengan suscripciones activas para el tipo de datos especificado.

dataType

Tipo de datos.

Devuelve: instrumentos financieros con suscripciones activas.

GetSubscriptions

public IEnumerable<Subscription> GetSubscriptions(ISubscriptionIdMessage message)

result = connectorSubscriptionManager.GetSubscriptions(message)

Resuelva las suscripciones para el mensaje especificado.

message

Mensaje con los ids de suscripción.

Devuelve: Suscripciones.

HandleConnected

public Actions HandleConnected(Subscription[] subscriptions)

result = connectorSubscriptionManager.HandleConnected(subscriptions)

Maneja el evento de conexión y restaura las suscripciones según sea necesario.

subscriptions

Suscripciones por defecto.

Devuelve: Acciones a aplicar.

HandleConnected

public Actions HandleConnected(Func<Subscription, bool> subscriptionFilter)

result = connectorSubscriptionManager.HandleConnected(subscriptionFilter)

Maneja el evento de conexión y restaura las suscripciones según sea necesario.

subscriptionFilter

Filtro para SubscriptionsOnConnect.

Devuelve: Acciones a aplicar.

ProcessLookupResponse``1

public IEnumerable<Subscription> ProcessLookupResponse<T>(ISubscriptionIdMessage message, T item)

result = connectorSubscriptionManager.ProcessLookupResponse(message, item)

Procese un elemento de respuesta de búsqueda.

message

Mensaje de búsqueda.

item

Mira el tema.

Devuelve: Suscripciones que recibieron el tema.

ProcessResponse

public Subscription ProcessResponse(SubscriptionResponseMessage response, ISubscriptionMessage originalMsg, bool unexpectedCancelled, Object[] items)

result = connectorSubscriptionManager.ProcessResponse(response, originalMsg, unexpectedCancelled, items)

Procese un mensaje de respuesta de suscripción.

response

Mensaje de respuesta.

originalMsg

Solicitud de suscripción original.

unexpectedCancelled

Indica que la suscripción activa fue cancelada debido al error.

items

Artículos de búsqueda recolectados.

Devuelve: Caso de suscripción.

ProcessSubscriptionFinishedMessage

public Subscription ProcessSubscriptionFinishedMessage(SubscriptionFinishedMessage message, Object[] items)

result = connectorSubscriptionManager.ProcessSubscriptionFinishedMessage(message, items)

Procese un mensaje final de suscripción.

message

Mensaje terminado.

items

Artículos de búsqueda recolectados.

Devuelve: Caso de suscripción.

ProcessSubscriptionOnlineMessage

public Subscription ProcessSubscriptionOnlineMessage(SubscriptionOnlineMessage message, Object[] items)

result = connectorSubscriptionManager.ProcessSubscriptionOnlineMessage(message, items)

Procese un mensaje online de suscripción.

message

Mensaje en línea.

items

Artículos de búsqueda recolectados.

Devuelve: Caso de suscripción.

Subscribe

public Actions Subscribe(Subscription subscription, bool isAllExtension)

result = connectorSubscriptionManager.Subscribe(subscription, isAllExtension)

Enviar una solicitud de suscripción.

subscription

Suscripción.

isAllExtension

Indica la extensión "todos los instrumentos financieros".

Devuelve: Acciones a aplicar.

TryGetSubscription

public Subscription TryGetSubscription(long id, bool ignoreAll, bool remove, DateTime? time)

result = connectorSubscriptionManager.TryGetSubscription(id, ignoreAll, remove, time)

Intente obtener la suscripción por id.

id

Suscripción id.

ignoreAll

Ignora el mapeo de "todos los instrumentos financieros".

remove

Retire de la caché.

time

Tiempo de servidor opcional.

Devuelve: Suscripción o .

UnSubscribe

public Actions UnSubscribe(Subscription subscription)

result = connectorSubscriptionManager.UnSubscribe(subscription)

Enviar una solicitud de suscripciones.

subscription

Suscripción.

Devuelve: Acciones a aplicar.

UnSubscribeAll

public Actions UnSubscribeAll()

result = connectorSubscriptionManager.UnSubscribeAll()

Describir todas las suscripciones activas.

Devuelve: Acciones a aplicar.

UpdateCandles

public IEnumerable<ValueTuple<Subscription, ICandleMessage>> UpdateCandles(CandleMessage message)

result = connectorSubscriptionManager.UpdateCandles(message)

Actualizar velas para suscripciones y devolver resultados actualizados.

message

Mensaje de vela.

Devuelve: Suscripciones actualizadas con velas.