SubscriptionReplayTracker

StockSharp.Messages

Segue as assinaturas activas para connectors que lidam com a reconexão internamente. Após a reconexão, fornece assinaturas clonadas com From = null (online- only, no history re- re- request).

Propriedades

Count

public int Count { get; }

value = subscriptionReplayTracker.Count

Número de assinaturas atualmente rastreadas.

Métodos

Clear

public void Clear()

subscriptionReplayTracker.Clear()

Limpar todas as assinaturas rastreadas. Chamada em reset/desconexão completa.

GetSubscriptionsForReplay

public IEnumerable<ISubscriptionMessage> GetSubscriptionsForReplay()

result = subscriptionReplayTracker.GetSubscriptionsForReplay()

Obter todas as assinaturas ativas para replay após uma reconexão interna. Retorna clones com From = null sob os IDs originais da transação para que a reconexão fique transparente para código acima do adaptador — assinantes externos continuam recebendo dados sob txId eles originalmente subscritos com.

Retorna: Mensagens de assinatura clonadas prontas para serem reenviadas.

Process

public void Process(ISubscriptionMessage message)

subscriptionReplayTracker.Process(message)

Acompanhe ou desfaça uma assinatura com base em IsSubscribe.

message: Mensagem de assinatura.

Track

public void Track(ISubscriptionMessage message)

subscriptionReplayTracker.Track(message)

Acompanhe uma assinatura. Ligue quando o adaptador receber uma mensagem de assinatura.

message: Mensagem de assinatura (IsSubscribe deve ser verdadeira).

Untrack

public bool Untrack(long originalTransactionId)

result = subscriptionReplayTracker.Untrack(originalTransactionId)

Parar de rastrear uma assinatura. Ligue quando o adaptador receber uma mensagem de cancelamento.

originalTransactionId: ID da transação original da assinatura a remover.

Retorna: se a subscrição foi encontrada e removida.