ISubscriptionManagerState

ReMapSubscriptionCount

public int ReMapSubscriptionCount { get; }

value = iSubscriptionManagerState.ReMapSubscriptionCount

Get count of pending remap subscriptions.

ReplaceIdCount

public int ReplaceIdCount { get; }

value = iSubscriptionManagerState.ReplaceIdCount

Get count of replace IDs.

AddHistoricalRequest

public void AddHistoricalRequest(long transactionId, ISubscriptionMessage subscription)

iSubscriptionManagerState.AddHistoricalRequest(transactionId, subscription)

Add historical request.

AddReMapSubscription

public void AddReMapSubscription(Message message)

iSubscriptionManagerState.AddReMapSubscription(message)

Add message to remap queue.

AddReplaceId

public void AddReplaceId(long newId, long originalId)

iSubscriptionManagerState.AddReplaceId(newId, originalId)

Add replace ID mapping.

AddSubscription

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

iSubscriptionManagerState.AddSubscription(transactionId, subscription, state)

Add subscription.

Clear

public void Clear()

iSubscriptionManagerState.Clear()

Clear all state.

ClearReMapSubscriptions

public void ClearReMapSubscriptions()

iSubscriptionManagerState.ClearReMapSubscriptions()

Clear remap subscriptions.

ClearReplaceIds

public void ClearReplaceIds()

iSubscriptionManagerState.ClearReplaceIds()

Clear all replace IDs.

ContainsHistoricalRequest

public bool ContainsHistoricalRequest(long transactionId)

result = iSubscriptionManagerState.ContainsHistoricalRequest(transactionId)

Check if contains historical request.

ContainsReplaceId

public bool ContainsReplaceId(long newId)

result = iSubscriptionManagerState.ContainsReplaceId(newId)

Check if contains replace ID.

GetActiveSubscriptions

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

result = iSubscriptionManagerState.GetActiveSubscriptions()

Get all active subscriptions for remapping.

GetAndClearReMapSubscriptions

public Message[] GetAndClearReMapSubscriptions()

result = iSubscriptionManagerState.GetAndClearReMapSubscriptions()

Get and clear remap subscriptions.

RemoveHistoricalRequest

public bool RemoveHistoricalRequest(long transactionId)

result = iSubscriptionManagerState.RemoveHistoricalRequest(transactionId)

Remove historical request.

RemoveReplaceId

public void RemoveReplaceId(long newId)

iSubscriptionManagerState.RemoveReplaceId(newId)

Remove replace ID mapping by new ID.

RemoveSubscription

public bool RemoveSubscription(long transactionId)

result = iSubscriptionManagerState.RemoveSubscription(transactionId)

Remove subscription.

TryGetAndRemoveHistoricalRequest

public bool TryGetAndRemoveHistoricalRequest(long transactionId, ISubscriptionMessage subscription)

result = iSubscriptionManagerState.TryGetAndRemoveHistoricalRequest(transactionId, subscription)

Try get and remove historical request.

TryGetHistoricalRequest

public bool TryGetHistoricalRequest(long transactionId, ISubscriptionMessage subscription)

result = iSubscriptionManagerState.TryGetHistoricalRequest(transactionId, subscription)

Try get historical request without removing.

TryGetNewId

public bool TryGetNewId(long originalId, long newId)

result = iSubscriptionManagerState.TryGetNewId(originalId, newId)

Try get new ID by original ID.

TryGetOriginalId

public bool TryGetOriginalId(long newId, long originalId)

result = iSubscriptionManagerState.TryGetOriginalId(newId, originalId)

Try get original ID by new ID.

TryGetSubscription

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

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

Try get subscription.

UpdateSubscriptionState

public void UpdateSubscriptionState(long transactionId, SubscriptionStates newState)

iSubscriptionManagerState.UpdateSubscriptionState(transactionId, newState)

Update subscription state.