Class ConsumerTransactionManager

Namespace

Silverback.Messaging.Consuming.Transaction

Assembly

Silverback.Integration.dll

Handles the consumer transaction.

public sealed class ConsumerTransactionManager : IConsumerTransactionManager

Inheritance

object

ConsumerTransactionManager

Implements

IConsumerTransactionManager

Inherited Members

object.GetType()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

ConsumerTransactionManager(ConsumerPipelineContext, ISilverbackLogger<ConsumerTransactionManager>)

Initializes a new instance of the ConsumerTransactionManager class.

public ConsumerTransactionManager(ConsumerPipelineContext context, ISilverbackLogger<ConsumerTransactionManager> logger)

Parameters

context ConsumerPipelineContext

The current ConsumerPipelineContext.

logger ISilverbackLogger<ConsumerTransactionManager>

The ISilverbackLogger.

Properties

Aborted

Gets the AsyncEvent<TArg> that is after the consumer is aborted.

public AsyncEvent<ConsumerPipelineContext> Aborted { get; }

Property Value

AsyncEvent<ConsumerPipelineContext>

Aborting

Gets the AsyncEvent<TArg> that is before the consumer is aborted.

public AsyncEvent<ConsumerPipelineContext> Aborting { get; }

Property Value

AsyncEvent<ConsumerPipelineContext>

Committed

Gets the AsyncEvent<TArg> that is after the consumer is committed.

public AsyncEvent<ConsumerPipelineContext> Committed { get; }

Property Value

AsyncEvent<ConsumerPipelineContext>

Committing

Gets the AsyncEvent<TArg> that is fired before the consumer is committed.

public AsyncEvent<ConsumerPipelineContext> Committing { get; }

Property Value

AsyncEvent<ConsumerPipelineContext>

Methods

CommitAsync()

Commits the transaction.

public Task CommitAsync()

Returns

Task

A Task representing the asynchronous operation.

RollbackAsync(Exception?, bool, bool, bool)

Aborts the transaction and causes the uncommitted changes to be rolled back.

public Task<bool> RollbackAsync(Exception? exception, bool commitConsumer = false, bool throwIfAlreadyCommitted = true, bool stopConsuming = true)

Parameters

exception Exception

The exception that caused the rollback.

commitConsumer bool

A value indicating whether the consumer have to be committed anyway. This depends on the error policy being applied.

throwIfAlreadyCommitted bool

A value indicating whether an exception must be thrown if the transaction was already committed.

stopConsuming bool

A value indicating whether the consumer must be stopped.

Returns

Task<bool>

A Task<TResult> representing the asynchronous operation. The task result contains a value indicating whether the rollback was performed.