Class SimpleMessageIdentifiersTracker

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

Inheritance

object

SimpleMessageIdentifiersTracker

Implements

IBrokerMessageIdentifiersTracker

Inherited Members

object.GetType()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Namespace: Silverback.Messaging.Broker.BrokerMessageIdentifiersTracking

Assembly: Silverback.Integration.dll

Syntax

public sealed class SimpleMessageIdentifiersTracker : IBrokerMessageIdentifiersTracker

Constructors

SimpleMessageIdentifiersTracker()

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

Declaration

public SimpleMessageIdentifiersTracker()

Methods

GetCommitIdentifiers()

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

Declaration

public 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

public IReadOnlyCollection<IBrokerMessageIdentifier> GetRollbackIdentifiers()

Returns

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

TrackIdentifier(IBrokerMessageIdentifier)

Tracks the specified identifier.

Declaration

public void TrackIdentifier(IBrokerMessageIdentifier identifier)

Parameters

Type	Name	Description
IBrokerMessageIdentifier	identifier	The identifier to be tracked.

Implements

IBrokerMessageIdentifiersTracker