SubscriptionManagerState

ReMapSubscriptionCount

public int ReMapSubscriptionCount { get; }

value = subscriptionManagerState.ReMapSubscriptionCount

Get count of pending remap subscriptions.

ReplaceIdCount

public int ReplaceIdCount { get; }

value = subscriptionManagerState.ReplaceIdCount

Get count of replace IDs.

AddHistoricalRequest

public void AddHistoricalRequest(long transactionId, ISubscriptionMessage subscription)

subscriptionManagerState.AddHistoricalRequest(transactionId, subscription)

Add historical request.

AddReMapSubscription

public void AddReMapSubscription(Message message)

subscriptionManagerState.AddReMapSubscription(message)

Add message to remap queue.

AddReplaceId

public void AddReplaceId(long newId, long originalId)

subscriptionManagerState.AddReplaceId(newId, originalId)

Add replace ID mapping.

AddSubscription

public void AddSubscription(long transactionId, ISubscriptionMessage subscription, SubscriptionStates state)

subscriptionManagerState.AddSubscription(transactionId, subscription, state)

Add subscription.

Clear

public void Clear()

subscriptionManagerState.Clear()

Clear all state.

ClearReMapSubscriptions

public void ClearReMapSubscriptions()

subscriptionManagerState.ClearReMapSubscriptions()

Clear remap subscriptions.

ClearReplaceIds

public void ClearReplaceIds()

subscriptionManagerState.ClearReplaceIds()

Clear all replace IDs.

ContainsHistoricalRequest

public bool ContainsHistoricalRequest(long transactionId)

result = subscriptionManagerState.ContainsHistoricalRequest(transactionId)

Check if contains historical request.

ContainsReplaceId

public bool ContainsReplaceId(long newId)

result = subscriptionManagerState.ContainsReplaceId(newId)

Check if contains replace ID.

GetActiveSubscriptions

public IEnumerable<ValueTuple<long, ISubscriptionMessage>> GetActiveSubscriptions()

result = subscriptionManagerState.GetActiveSubscriptions()

Get all active subscriptions for remapping.

GetAndClearReMapSubscriptions

public Message[] GetAndClearReMapSubscriptions()

result = subscriptionManagerState.GetAndClearReMapSubscriptions()

Get and clear remap subscriptions.

RemoveHistoricalRequest

public bool RemoveHistoricalRequest(long transactionId)

result = subscriptionManagerState.RemoveHistoricalRequest(transactionId)

Remove historical request.

RemoveReplaceId

public void RemoveReplaceId(long newId)

subscriptionManagerState.RemoveReplaceId(newId)

Remove replace ID mapping by new ID.

RemoveSubscription

public bool RemoveSubscription(long transactionId)

result = subscriptionManagerState.RemoveSubscription(transactionId)

Remove subscription.

TryGetAndRemoveHistoricalRequest

public bool TryGetAndRemoveHistoricalRequest(long transactionId, ISubscriptionMessage subscription)

result = subscriptionManagerState.TryGetAndRemoveHistoricalRequest(transactionId, subscription)

Try get and remove historical request.

TryGetHistoricalRequest

public bool TryGetHistoricalRequest(long transactionId, ISubscriptionMessage subscription)

result = subscriptionManagerState.TryGetHistoricalRequest(transactionId, subscription)

Try get historical request without removing.

TryGetNewId

public bool TryGetNewId(long originalId, long newId)

result = subscriptionManagerState.TryGetNewId(originalId, newId)

Try get new ID by original ID.

TryGetOriginalId

public bool TryGetOriginalId(long newId, long originalId)

result = subscriptionManagerState.TryGetOriginalId(newId, originalId)

Try get original ID by new ID.

TryGetSubscription

public bool TryGetSubscription(long transactionId, ISubscriptionMessage subscription, SubscriptionStates state)

result = subscriptionManagerState.TryGetSubscription(transactionId, subscription, state)

Try get subscription.

UpdateSubscriptionState

public void UpdateSubscriptionState(long transactionId, SubscriptionStates newState)

subscriptionManagerState.UpdateSubscriptionState(transactionId, newState)

Update subscription state.