Class AbstractPlatformTransactionManager

Namespace

Steeltoe.Common.Transaction

Assembly

Steeltoe.Common.dll

public abstract class AbstractPlatformTransactionManager : IPlatformTransactionManager

Inheritance

object

AbstractPlatformTransactionManager

Implements

IPlatformTransactionManager

Derived

RabbitTransactionManager

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

AbstractPlatformTransactionManager(ILogger)

protected AbstractPlatformTransactionManager(ILogger logger = null)

Parameters

logger ILogger

Fields

SYNCHRONIZATION_ALWAYS

public const int SYNCHRONIZATION_ALWAYS = 0

Field Value

int

SYNCHRONIZATION_NEVER

public const int SYNCHRONIZATION_NEVER = 2

Field Value

int

SYNCHRONIZATION_ON_ACTUAL_TRANSACTION

public const int SYNCHRONIZATION_ON_ACTUAL_TRANSACTION = 1

Field Value

int

_logger

protected readonly ILogger _logger

Field Value

ILogger

Properties

DefaultTimeout

public virtual int DefaultTimeout { get; set; }

Property Value

int

FailEarlyOnGlobalRollbackOnly

public virtual bool FailEarlyOnGlobalRollbackOnly { get; set; }

Property Value

bool

GlobalRollbackOnParticipationFailure

public virtual bool GlobalRollbackOnParticipationFailure { get; set; }

Property Value

bool

NestedTransactionAllowed

public virtual bool NestedTransactionAllowed { get; set; }

Property Value

bool

RollbackOnCommitFailure

public virtual bool RollbackOnCommitFailure { get; set; }

Property Value

bool

ShouldCommitOnGlobalRollbackOnly

protected virtual bool ShouldCommitOnGlobalRollbackOnly { get; }

Property Value

bool

TransactionSynchronization

public virtual int TransactionSynchronization { get; set; }

Property Value

int

UseSavepointForNestedTransaction

protected virtual bool UseSavepointForNestedTransaction { get; }

Property Value

bool

ValidateExistingTransaction

public virtual bool ValidateExistingTransaction { get; set; }

Property Value

bool

Methods

Commit(ITransactionStatus)

public virtual void Commit(ITransactionStatus status)

Parameters

status ITransactionStatus

DetermineTimeout(ITransactionDefinition)

protected virtual int DetermineTimeout(ITransactionDefinition definition)

Parameters

definition ITransactionDefinition

Returns

int

DoBegin(object, ITransactionDefinition)

protected abstract void DoBegin(object transaction, ITransactionDefinition definition)

Parameters

transaction object

definition ITransactionDefinition

DoCleanupAfterCompletion(object)

protected virtual void DoCleanupAfterCompletion(object transaction)

Parameters

transaction object

DoCommit(DefaultTransactionStatus)

protected abstract void DoCommit(DefaultTransactionStatus status)

Parameters

status DefaultTransactionStatus

DoGetTransaction()

protected abstract object DoGetTransaction()

Returns

object

DoResume(object, object)

protected virtual void DoResume(object transaction, object suspendedResources)

Parameters

transaction object

suspendedResources object

DoRollback(DefaultTransactionStatus)

protected abstract void DoRollback(DefaultTransactionStatus status)

Parameters

status DefaultTransactionStatus

DoSetRollbackOnly(DefaultTransactionStatus)

protected virtual void DoSetRollbackOnly(DefaultTransactionStatus status)

Parameters

status DefaultTransactionStatus

DoSuspend(object)

protected virtual object DoSuspend(object transaction)

Parameters

transaction object

Returns

object

GetTransaction(ITransactionDefinition)

public virtual ITransactionStatus GetTransaction(ITransactionDefinition definition)

Parameters

definition ITransactionDefinition

Returns

ITransactionStatus

InvokeAfterCompletion(List<ITransactionSynchronization>, int)

protected virtual void InvokeAfterCompletion(List<ITransactionSynchronization> synchronizations, int completionStatus)

Parameters

synchronizations List<ITransactionSynchronization>

completionStatus int

IsExistingTransaction(object)

protected virtual bool IsExistingTransaction(object transaction)

Parameters

transaction object

Returns

bool

NewTransactionStatus(ITransactionDefinition, object, bool, bool, object)

protected virtual DefaultTransactionStatus NewTransactionStatus(ITransactionDefinition definition, object transaction, bool newTransaction, bool newSynchronization, object suspendedResources)

Parameters

definition ITransactionDefinition

transaction object

newTransaction bool

newSynchronization bool

suspendedResources object

Returns

DefaultTransactionStatus

PrepareForCommit(DefaultTransactionStatus)

protected virtual void PrepareForCommit(DefaultTransactionStatus status)

Parameters

status DefaultTransactionStatus

PrepareSynchronization(DefaultTransactionStatus, ITransactionDefinition)

protected virtual void PrepareSynchronization(DefaultTransactionStatus status, ITransactionDefinition definition)

Parameters

status DefaultTransactionStatus

definition ITransactionDefinition

PrepareTransactionStatus(ITransactionDefinition, object, bool, bool, object)

protected virtual DefaultTransactionStatus PrepareTransactionStatus(ITransactionDefinition definition, object transaction, bool newTransaction, bool newSynchronization, object suspendedResources)

Parameters

definition ITransactionDefinition

transaction object

newTransaction bool

newSynchronization bool

suspendedResources object

Returns

DefaultTransactionStatus

RegisterAfterCompletionWithExistingTransaction(object, List<ITransactionSynchronization>)

protected virtual void RegisterAfterCompletionWithExistingTransaction(object transaction, List<ITransactionSynchronization> synchronizations)

Parameters

transaction object

synchronizations List<ITransactionSynchronization>

Resume(object, SuspendedResourcesHolder)

protected virtual void Resume(object transaction, AbstractPlatformTransactionManager.SuspendedResourcesHolder resourcesHolder)

Parameters

transaction object

resourcesHolder AbstractPlatformTransactionManager.SuspendedResourcesHolder

Rollback(ITransactionStatus)

public virtual void Rollback(ITransactionStatus status)

Parameters

status ITransactionStatus

Suspend(object)

protected virtual AbstractPlatformTransactionManager.SuspendedResourcesHolder Suspend(object transaction)

Parameters

transaction object

Returns

AbstractPlatformTransactionManager.SuspendedResourcesHolder

TriggerBeforeCommit(DefaultTransactionStatus)

protected virtual void TriggerBeforeCommit(DefaultTransactionStatus status)

Parameters

status DefaultTransactionStatus

TriggerBeforeCompletion(DefaultTransactionStatus)

protected virtual void TriggerBeforeCompletion(DefaultTransactionStatus status)

Parameters

status DefaultTransactionStatus