org.springframework.amqp.rabbit.connection

Class RabbitResourceHolder

java.lang.Object

org.springframework.transaction.support.ResourceHolderSupport

org.springframework.amqp.rabbit.connection.RabbitResourceHolder

All Implemented Interfaces:

org.springframework.transaction.support.ResourceHolder

public class RabbitResourceHolder
extends org.springframework.transaction.support.ResourceHolderSupport

Rabbit resource holder, wrapping a RabbitMQ Connection and Channel. RabbitTransactionManager binds instances of this class to the thread, for a given Rabbit ConnectionFactory.

Note: This is an SPI class, not intended to be used by applications.

See Also:

RabbitTransactionManager, RabbitTemplate

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.List<com.rabbitmq.client.Channel>	channels
private java.util.Map<Connection,java.util.List<com.rabbitmq.client.Channel>>	channelsPerConnection
private java.util.List<Connection>	connections
private org.springframework.util.MultiValueMap<com.rabbitmq.client.Channel,java.lang.Long>	deliveryTags
private boolean	frozen
private static org.apache.commons.logging.Log	logger
private boolean	releaseAfterCompletion
private boolean	transactional

Constructor Summary

Constructors

Constructor and Description
RabbitResourceHolder() Create a new RabbitResourceHolder that is open for resources to be added.
RabbitResourceHolder(com.rabbitmq.client.Channel channel, boolean releaseAfterCompletion)

Method Summary

Modifier and Type	Method and Description
void	addChannel(com.rabbitmq.client.Channel channel)
void	addChannel(com.rabbitmq.client.Channel channel, Connection connection)
void	addConnection(Connection connection)
void	addDeliveryTag(com.rabbitmq.client.Channel channel, long deliveryTag)
void	closeAll()
void	commitAll()
boolean	containsChannel(com.rabbitmq.client.Channel channel)
com.rabbitmq.client.Channel	getChannel()
Connection	getConnection()
Connection	getConnection(java.lang.Class<? extends Connection> connectionType)
boolean	isChannelTransactional()
boolean	isFrozen()
boolean	isReleaseAfterCompletion() Whether the resources should be released after transaction completion.
void	rollbackAll()

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

clear, getDeadline, getTimeToLiveInMillis, getTimeToLiveInSeconds, hasTimeout, isOpen, isRollbackOnly, isSynchronizedWithTransaction, isVoid, released, requested, reset, setRollbackOnly, setSynchronizedWithTransaction, setTimeoutInMillis, setTimeoutInSeconds, unbound

Methods inherited from class java.lang.Object

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

Field Detail

logger

private static final org.apache.commons.logging.Log logger

frozen

private final boolean frozen

See Also:

Constant Field Values

connections

private final java.util.List<Connection> connections

channels

private final java.util.List<com.rabbitmq.client.Channel> channels

channelsPerConnection

private final java.util.Map<Connection,java.util.List<com.rabbitmq.client.Channel>> channelsPerConnection

deliveryTags

private final org.springframework.util.MultiValueMap<com.rabbitmq.client.Channel,java.lang.Long> deliveryTags

transactional

private boolean transactional

releaseAfterCompletion

private boolean releaseAfterCompletion

Constructor Detail

RabbitResourceHolder

public RabbitResourceHolder()

Create a new RabbitResourceHolder that is open for resources to be added.

RabbitResourceHolder

public RabbitResourceHolder(com.rabbitmq.client.Channel channel,
                            boolean releaseAfterCompletion)

Parameters:

channel - a channel to add

releaseAfterCompletion - true if the channel should be released after completion.

Method Detail

isFrozen

public final boolean isFrozen()

isReleaseAfterCompletion

public boolean isReleaseAfterCompletion()

Whether the resources should be released after transaction completion. Default true. Listener containers set to false because the listener continues to use the channel.

Returns:

true if the resources should be released.

addConnection

public final void addConnection(Connection connection)

addChannel

public final void addChannel(com.rabbitmq.client.Channel channel)

addChannel

public final void addChannel(com.rabbitmq.client.Channel channel,
                             Connection connection)

containsChannel

public boolean containsChannel(com.rabbitmq.client.Channel channel)

getConnection

public Connection getConnection()

getConnection

public Connection getConnection(java.lang.Class<? extends Connection> connectionType)

getChannel

public com.rabbitmq.client.Channel getChannel()

commitAll

public void commitAll()
               throws AmqpException

Throws:

AmqpException

closeAll

public void closeAll()

addDeliveryTag

public void addDeliveryTag(com.rabbitmq.client.Channel channel,
                           long deliveryTag)

rollbackAll

public void rollbackAll()

isChannelTransactional

public boolean isChannelTransactional()

Returns:

true if the channels in this holder are transactional