Class SimpleMessageIdentifiersTracker

Namespace

Silverback.Messaging.Broker.BrokerMessageIdentifiersTracking

Assembly

Silverback.Integration.dll

Keeps track of the identifiers (offsets or similar) of the messages being produced or consumed.

public sealed class SimpleMessageIdentifiersTracker : IBrokerMessageIdentifiersTracker

Inheritance

object

SimpleMessageIdentifiersTracker

Implements

IBrokerMessageIdentifiersTracker

Inherited Members

object.GetType()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

SimpleMessageIdentifiersTracker()

public SimpleMessageIdentifiersTracker()

Methods

GetCommitIdentifiers()

Gets the identifiers to be used to commit after successful processing.

public IReadOnlyCollection<IBrokerMessageIdentifier> GetCommitIdentifiers()

Returns

IReadOnlyCollection<IBrokerMessageIdentifier>

The identifiers to be used to commit.

GetRollbackIdentifiers()

Gets the identifiers to be used to roll back in case of error.

public IReadOnlyCollection<IBrokerMessageIdentifier> GetRollbackIdentifiers()

Returns

IReadOnlyCollection<IBrokerMessageIdentifier>

The identifiers to be used to roll back.

TrackIdentifier(IBrokerMessageIdentifier)

Tracks the specified identifier.

public void TrackIdentifier(IBrokerMessageIdentifier identifier)

Parameters

identifier IBrokerMessageIdentifier

The identifier to be tracked.