SubscriptionReplayTracker
Pistas activas suscripciones para connectorsque manejan la reconexión internamente. Después de la reconexión, proporciona suscripciones clonadas con From = null (sólo en línea, sin re-repetición de la historia).
Propiedades
public int Count { get; }
value = subscriptionReplayTracker.Count
Número de suscripciones actualmente rastreadas.
Métodos
public void Clear()
subscriptionReplayTracker.Clear()
Limpiar todas las suscripciones rastreadas. Llame al reset / desconexión completo.
public IEnumerable<ISubscriptionMessage> GetSubscriptionsForReplay()
result = subscriptionReplayTracker.GetSubscriptionsForReplay()
Retorne clones con From = null bajo los IDs de transacción originales para que la reconexión se mantenga transparente a la clave sobre el adaptador, los suscriptores externos siguen recibiendo datos bajo txId que originalmente se suscribió con.
Devuelve: Los mensajes de suscripción cerrados listos para ser reenviados.
public void Process(ISubscriptionMessage message)
subscriptionReplayTracker.Process(message)
Pista o desvíe una suscripción basada en IsSubscribe.
- message
- Mensaje de suscripción.
public void Track(ISubscriptionMessage message)
subscriptionReplayTracker.Track(message)
Haz un seguimiento de la suscripción. Llama cuando el adaptador reciba un mensaje de suscripción.
- message
- El mensaje de inscripción (IsSubscribe@ debe ser verdadero).
public bool Untrack(long originalTransactionId)
result = subscriptionReplayTracker.Untrack(originalTransactionId)
Deja de rastrear una suscripción. Llama cuando el adaptador reciba un mensaje de suscripción.
- originalTransactionId
- ID de transacción original de la suscripción para eliminar.
Devuelve: si la suscripción fue encontrada y eliminada.