Interface IBrokerMessageIdentifiersTracker

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

Namespace: Silverback.Messaging.Broker.BrokerMessageIdentifiersTracking

Assembly: Silverback.Integration.dll

Syntax

public interface IBrokerMessageIdentifiersTracker

Methods

GetCommitIdentifiers()

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

Declaration

IReadOnlyCollection<IBrokerMessageIdentifier> GetCommitIdentifiers()

Returns

Type	Description
IReadOnlyCollection<IBrokerMessageIdentifier>	The identifiers to be used to commit.

GetRollbackIdentifiers()

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

Declaration

IReadOnlyCollection<IBrokerMessageIdentifier> GetRollbackIdentifiers()

Returns

Type	Description
IReadOnlyCollection<IBrokerMessageIdentifier>	The identifiers to be used to roll back.

TrackIdentifier(IBrokerMessageIdentifier)

Tracks the specified identifier.

Declaration

void TrackIdentifier(IBrokerMessageIdentifier identifier)

Parameters

Type	Name	Description
IBrokerMessageIdentifier	identifier	The identifier to be tracked.