Interface IBrokerMessageIdentifiersTracker

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 interface IBrokerMessageIdentifiersTracker

Methods

GetCommitIdentifiers()

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

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.

IReadOnlyCollection<IBrokerMessageIdentifier> GetRollbackIdentifiers()

Returns

IReadOnlyCollection<IBrokerMessageIdentifier>

The identifiers to be used to roll back.

TrackIdentifier(IBrokerMessageIdentifier)

Tracks the specified identifier.

void TrackIdentifier(IBrokerMessageIdentifier identifier)

Parameters

identifier IBrokerMessageIdentifier

The identifier to be tracked.