org.springframework.amqp.rabbit.connection

Class ConnectionFactoryUtils.RabbitResourceSynchronization

java.lang.Object

org.springframework.transaction.support.ResourceHolderSynchronization<RabbitResourceHolder,java.lang.Object>

org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.RabbitResourceSynchronization

All Implemented Interfaces:

org.springframework.transaction.support.TransactionSynchronization

Enclosing class:

ConnectionFactoryUtils

private static class ConnectionFactoryUtils.RabbitResourceSynchronization
extends org.springframework.transaction.support.ResourceHolderSynchronization<RabbitResourceHolder,java.lang.Object>

Callback for resource cleanup at the end of a non-native RabbitMQ transaction (e.g. when participating in a JtaTransactionManager transaction).

See Also:

org.springframework.transaction.jta.JtaTransactionManager

Field Summary

Fields

Modifier and Type	Field and Description
private RabbitResourceHolder	resourceHolder
private boolean	transacted

Fields inherited from interface org.springframework.transaction.support.TransactionSynchronization

STATUS_COMMITTED, STATUS_ROLLED_BACK, STATUS_UNKNOWN

Constructor Summary

Constructors

Constructor and Description
RabbitResourceSynchronization(RabbitResourceHolder resourceHolder, java.lang.Object resourceKey, boolean transacted)

Method Summary

Modifier and Type	Method and Description
void	afterCompletion(int status)
protected void	processResourceAfterCommit(RabbitResourceHolder resourceHolder)
protected void	releaseResource(RabbitResourceHolder resourceHolder, java.lang.Object resourceKey)
protected boolean	shouldReleaseBeforeCompletion()

Methods inherited from class org.springframework.transaction.support.ResourceHolderSynchronization

afterCommit, beforeCommit, beforeCompletion, cleanupResource, flush, flushResource, resume, shouldReleaseAfterCompletion, shouldUnbindAtCompletion, suspend

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

transacted

private final boolean transacted

resourceHolder

private final RabbitResourceHolder resourceHolder

Constructor Detail

RabbitResourceSynchronization

public RabbitResourceSynchronization(RabbitResourceHolder resourceHolder,
                                     java.lang.Object resourceKey,
                                     boolean transacted)

Method Detail

shouldReleaseBeforeCompletion

protected boolean shouldReleaseBeforeCompletion()

Overrides:

shouldReleaseBeforeCompletion in class org.springframework.transaction.support.ResourceHolderSynchronization<RabbitResourceHolder,java.lang.Object>

processResourceAfterCommit

protected void processResourceAfterCommit(RabbitResourceHolder resourceHolder)

Overrides:

processResourceAfterCommit in class org.springframework.transaction.support.ResourceHolderSynchronization<RabbitResourceHolder,java.lang.Object>

afterCompletion

public void afterCompletion(int status)

Specified by:

afterCompletion in interface org.springframework.transaction.support.TransactionSynchronization

Overrides:

afterCompletion in class org.springframework.transaction.support.ResourceHolderSynchronization<RabbitResourceHolder,java.lang.Object>

releaseResource

protected void releaseResource(RabbitResourceHolder resourceHolder,
                               java.lang.Object resourceKey)

Overrides:

releaseResource in class org.springframework.transaction.support.ResourceHolderSynchronization<RabbitResourceHolder,java.lang.Object>