Class ConsumerTransactionManager

Inheritance
System.Object
ConsumerTransactionManager
Inherited Members
System.Object.Equals(System.Object)
System.Object.Equals(System.Object, System.Object)
System.Object.GetHashCode()
System.Object.GetType()
System.Object.MemberwiseClone()
System.Object.ReferenceEquals(System.Object, System.Object)
System.Object.ToString()
Namespace: Silverback.Messaging.Inbound.Transaction
Assembly: Silverback.Integration.dll
Syntax
public sealed class ConsumerTransactionManager : IConsumerTransactionManager

Constructors

| Improve this doc View source

ConsumerTransactionManager(ConsumerPipelineContext, IInboundLogger<ConsumerTransactionManager>)

Initializes a new instance of the ConsumerTransactionManager class.

Declaration
public ConsumerTransactionManager(ConsumerPipelineContext context, IInboundLogger<ConsumerTransactionManager> logger)
Parameters
Type Name Description
ConsumerPipelineContext context

The current ConsumerPipelineContext.
IInboundLogger<ConsumerTransactionManager> logger

The ISilverbackLogger.

Properties

| Improve this doc View source

IsCompleted

Declaration
public bool IsCompleted { get; }
Property Value
Type Description
System.Boolean

Methods

| Improve this doc View source

CommitAsync()

Declaration
public async Task CommitAsync()
Returns
Type Description
System.Threading.Tasks.Task
| Improve this doc View source

Enlist(ITransactional)

Declaration
public void Enlist(ITransactional transactionalService)
Parameters
Type Name Description
ITransactional transactionalService
| Improve this doc View source

RollbackAsync(Exception, Boolean, Boolean, Boolean)

Declaration
public async Task<bool> RollbackAsync(Exception exception, bool commitConsumer = false, bool throwIfAlreadyCommitted = true, bool stopConsuming = true)
Parameters
Type Name Description
System.Exception exception
System.Boolean commitConsumer
System.Boolean throwIfAlreadyCommitted
System.Boolean stopConsuming
Returns
Type Description
System.Threading.Tasks.Task<System.Boolean>

Implements