Class RabbitTransactionManager

Namespace

Steeltoe.Messaging.RabbitMQ.Transaction

Assembly

Steeltoe.Messaging.RabbitMQ.dll

public class RabbitTransactionManager : AbstractPlatformTransactionManager, IResourceTransactionManager, IPlatformTransactionManager

Inheritance

object

AbstractPlatformTransactionManager

RabbitTransactionManager

Implements

IResourceTransactionManager

IPlatformTransactionManager

Inherited Members

AbstractPlatformTransactionManager.SYNCHRONIZATION_ALWAYS

AbstractPlatformTransactionManager.SYNCHRONIZATION_ON_ACTUAL_TRANSACTION

AbstractPlatformTransactionManager.SYNCHRONIZATION_NEVER

AbstractPlatformTransactionManager._logger

AbstractPlatformTransactionManager.TransactionSynchronization

AbstractPlatformTransactionManager.DefaultTimeout

AbstractPlatformTransactionManager.NestedTransactionAllowed

AbstractPlatformTransactionManager.ValidateExistingTransaction

AbstractPlatformTransactionManager.GlobalRollbackOnParticipationFailure

AbstractPlatformTransactionManager.FailEarlyOnGlobalRollbackOnly

AbstractPlatformTransactionManager.RollbackOnCommitFailure

AbstractPlatformTransactionManager.GetTransaction(ITransactionDefinition)

AbstractPlatformTransactionManager.Commit(ITransactionStatus)

AbstractPlatformTransactionManager.Rollback(ITransactionStatus)

AbstractPlatformTransactionManager.PrepareTransactionStatus(ITransactionDefinition, object, bool, bool, object)

AbstractPlatformTransactionManager.NewTransactionStatus(ITransactionDefinition, object, bool, bool, object)

AbstractPlatformTransactionManager.PrepareSynchronization(DefaultTransactionStatus, ITransactionDefinition)

AbstractPlatformTransactionManager.DetermineTimeout(ITransactionDefinition)

AbstractPlatformTransactionManager.Suspend(object)

AbstractPlatformTransactionManager.Resume(object, AbstractPlatformTransactionManager.SuspendedResourcesHolder)

AbstractPlatformTransactionManager.TriggerBeforeCommit(DefaultTransactionStatus)

AbstractPlatformTransactionManager.TriggerBeforeCompletion(DefaultTransactionStatus)

AbstractPlatformTransactionManager.InvokeAfterCompletion(List<ITransactionSynchronization>, int)

AbstractPlatformTransactionManager.PrepareForCommit(DefaultTransactionStatus)

AbstractPlatformTransactionManager.RegisterAfterCompletionWithExistingTransaction(object, List<ITransactionSynchronization>)

AbstractPlatformTransactionManager.ShouldCommitOnGlobalRollbackOnly

AbstractPlatformTransactionManager.UseSavepointForNestedTransaction

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

RabbitTransactionManager()

public RabbitTransactionManager()

RabbitTransactionManager(IConnectionFactory, ILogger)

public RabbitTransactionManager(IConnectionFactory connectionFactory, ILogger logger = null)

Parameters

connectionFactory IConnectionFactory

logger ILogger

Properties

ConnectionFactory

public IConnectionFactory ConnectionFactory { get; set; }

Property Value

IConnectionFactory

ResourceFactory

public object ResourceFactory { get; }

Property Value

object

Methods

DoBegin(object, ITransactionDefinition)

protected override void DoBegin(object transaction, ITransactionDefinition definition)

Parameters

transaction object

definition ITransactionDefinition

DoCleanupAfterCompletion(object)

protected override void DoCleanupAfterCompletion(object transaction)

Parameters

transaction object

DoCommit(DefaultTransactionStatus)

protected override void DoCommit(DefaultTransactionStatus status)

Parameters

status DefaultTransactionStatus

DoGetTransaction()

protected override object DoGetTransaction()

Returns

object

DoResume(object, object)

protected override void DoResume(object transaction, object suspendedResources)

Parameters

transaction object

suspendedResources object

DoRollback(DefaultTransactionStatus)

protected override void DoRollback(DefaultTransactionStatus status)

Parameters

status DefaultTransactionStatus

DoSetRollbackOnly(DefaultTransactionStatus)

protected override void DoSetRollbackOnly(DefaultTransactionStatus status)

Parameters

status DefaultTransactionStatus

DoSuspend(object)

protected override object DoSuspend(object transaction)

Parameters

transaction object

Returns

object

IsExistingTransaction(object)

protected override bool IsExistingTransaction(object transaction)

Parameters

transaction object

Returns

bool