ConnectorSubscriptionManager

ConnectorSubscriptionManager

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

connectorSubscriptionManager = ConnectorSubscriptionManager(logReceiver, transactionIdGenerator, sendUnsubscribeWhenDisconnected)

Gerencia assinaturas e seu ciclo de vida.

logReceiver

Receptor de registo.

transactionIdGenerator

Gerador de identificação de transação.

sendUnsubscribeWhenDisconnected

Indica se deve enviar os pedidos de cancelamento da subscrição enquanto estiver desligado.

ConnectionState

public ConnectionStates ConnectionState { get; set; }

value = connectorSubscriptionManager.ConnectionState
connectorSubscriptionManager.ConnectionState = value

Estado atual da conexão.

IsRestoreSubscriptionOnNormalReconnect

public bool IsRestoreSubscriptionOnNormalReconnect { get; set; }

value = connectorSubscriptionManager.IsRestoreSubscriptionOnNormalReconnect
connectorSubscriptionManager.IsRestoreSubscriptionOnNormalReconnect = value

Restaurar assinatura ao reconectar.

SendUnsubscribeWhenDisconnected

public bool SendUnsubscribeWhenDisconnected { get; }

value = connectorSubscriptionManager.SendUnsubscribeWhenDisconnected

Indica se deve enviar os pedidos de cancelamento da subscrição enquanto estiver desligado.

Subscriptions

public IEnumerable<Subscription> Subscriptions { get; }

value = connectorSubscriptionManager.Subscriptions

Imagem das assinaturas actuais.

SubscriptionsOnConnect

public CachedSynchronizedSet<Subscription> SubscriptionsOnConnect { get; }

value = connectorSubscriptionManager.SubscriptionsOnConnect

Enviar assinaturas em ligação.

TransactionIdGenerator

public IdGenerator TransactionIdGenerator { get; set; }

value = connectorSubscriptionManager.TransactionIdGenerator
connectorSubscriptionManager.TransactionIdGenerator = value

Gerador de identificação de transação.

ClearCache

public void ClearCache()

connectorSubscriptionManager.ClearCache()

Limpar o estado interno.

GetSubscribers

public IEnumerable<SecurityId> GetSubscribers(DataType dataType)

result = connectorSubscriptionManager.GetSubscribers(dataType)

Obtenha instrumentos financeiros que tenham assinaturas ativas para o tipo de dados especificado.

dataType

Tipo de dados.

Retorna: Instrumentos financeiros com assinaturas activas.

GetSubscriptions

public IEnumerable<Subscription> GetSubscriptions(ISubscriptionIdMessage message)

result = connectorSubscriptionManager.GetSubscriptions(message)

Resolver as assinaturas da mensagem especificada.

message

Mensagem com IDs de assinatura.

Retorna: Assinaturas.

HandleConnected

public Actions HandleConnected(Subscription[] subscriptions)

result = connectorSubscriptionManager.HandleConnected(subscriptions)

Lidar com eventos de conexão e restaurar assinaturas conforme necessário.

subscriptions

Assinaturas padrão.

Retorna: Acções a aplicar.

HandleConnected

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

result = connectorSubscriptionManager.HandleConnected(subscriptionFilter)

Lidar com eventos de conexão e restaurar assinaturas conforme necessário.

subscriptionFilter

Filtro para SubscriptionsOnConnect.

Retorna: Acções a aplicar.

ProcessLookupResponse``1

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

result = connectorSubscriptionManager.ProcessLookupResponse(message, item)

Processe um item de resposta de pesquisa.

message

Procura uma mensagem.

item

Procura o item.

Retorna: Assinaturas que receberam o item.

ProcessResponse

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

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

Processe uma mensagem de resposta à subscrição.

response

Mensagem de resposta.

originalMsg

Pedido de subscrição original.

unexpectedCancelled

Indica que a subscrição activa foi cancelada devido a erro.

items

Artigos de pesquisa recolhidos.

Retorna: Exemplo de assinatura.

ProcessSubscriptionFinishedMessage

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

result = connectorSubscriptionManager.ProcessSubscriptionFinishedMessage(message, items)

Processar uma mensagem de subscrição terminada.

message

Mensagem terminada.

items

Artigos de pesquisa recolhidos.

Retorna: Exemplo de assinatura.

ProcessSubscriptionOnlineMessage

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

result = connectorSubscriptionManager.ProcessSubscriptionOnlineMessage(message, items)

Processe uma mensagem online de assinatura.

message

Mensagem online.

items

Artigos de pesquisa recolhidos.

Retorna: Exemplo de assinatura.

Subscribe

public Actions Subscribe(Subscription subscription, bool isAllExtension)

result = connectorSubscriptionManager.Subscribe(subscription, isAllExtension)

Envie um pedido de subscrição.

subscription

Assinatura.

isAllExtension

Indica "todos os instrumentos financeiros".

Retorna: Acções a aplicar.

TryGetSubscription

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

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

Tente obter a subscrição por ID.

id

ID da assinatura.

ignoreAll

Ignorar o mapeamento de "todos os instrumentos financeiros".

remove

Remova da 'cache'.

time

Hora do servidor opcional.

Retorna: Assinatura ou .

UnSubscribe

public Actions UnSubscribe(Subscription subscription)

result = connectorSubscriptionManager.UnSubscribe(subscription)

Envie um pedido de cancelamento da subscrição.

subscription

Assinatura.

Retorna: Acções a aplicar.

UnSubscribeAll

public Actions UnSubscribeAll()

result = connectorSubscriptionManager.UnSubscribeAll()

Desmarcar todas as assinaturas ativas.

Retorna: Acções a aplicar.

UpdateCandles

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

result = connectorSubscriptionManager.UpdateCandles(message)

Atualizar velas para assinaturas e retornar resultados atualizados.

message

Mensagem de vela.

Retorna: Assinaturas atualizadas com velas.