| Package | Description |
|---|---|
| org.springframework.amqp.rabbit.connection |
Provides classes related to connections.
|
| org.springframework.amqp.rabbit.listener |
Provides classes for message listener containers.
|
| org.springframework.amqp.rabbit.transaction |
Provides classes supporting transactions in Spring Rabbit.
|
| Modifier and Type | Field and Description |
|---|---|
private RabbitResourceHolder |
ConnectionFactoryUtils.RabbitResourceSynchronization.resourceHolder |
| Modifier and Type | Method and Description |
|---|---|
private static RabbitResourceHolder |
ConnectionFactoryUtils.doGetTransactionalResourceHolder(ConnectionFactory connectionFactory,
ConnectionFactoryUtils.ResourceFactory resourceFactory)
Obtain a RabbitMQ Channel that is synchronized with the current transaction, if any.
|
protected RabbitResourceHolder |
RabbitAccessor.getTransactionalResourceHolder() |
static RabbitResourceHolder |
ConnectionFactoryUtils.getTransactionalResourceHolder(ConnectionFactory connectionFactory,
boolean synchedLocalTransactionAllowed)
Obtain a RabbitMQ Channel that is synchronized with the current transaction, if any.
|
| Modifier and Type | Method and Description |
|---|---|
static void |
ConnectionFactoryUtils.bindResourceToTransaction(RabbitResourceHolder resourceHolder,
ConnectionFactory connectionFactory,
boolean synched) |
com.rabbitmq.client.Channel |
ConnectionFactoryUtils.ResourceFactory.getChannel(RabbitResourceHolder holder)
Fetch an appropriate Channel from the given RabbitResourceHolder.
|
protected com.rabbitmq.client.Channel |
RabbitAccessor.getChannel(RabbitResourceHolder holder)
Fetch an appropriate Channel from the given RabbitResourceHolder.
|
Connection |
ConnectionFactoryUtils.ResourceFactory.getConnection(RabbitResourceHolder holder)
Fetch an appropriate Connection from the given RabbitResourceHolder.
|
protected Connection |
RabbitAccessor.getConnection(RabbitResourceHolder holder)
Fetch an appropriate Connection from the given RabbitResourceHolder.
|
protected void |
ConnectionFactoryUtils.RabbitResourceSynchronization.processResourceAfterCommit(RabbitResourceHolder resourceHolder) |
protected void |
ConnectionFactoryUtils.RabbitResourceSynchronization.releaseResource(RabbitResourceHolder resourceHolder,
java.lang.Object resourceKey) |
static void |
ConnectionFactoryUtils.releaseResources(RabbitResourceHolder resourceHolder) |
| Constructor and Description |
|---|
RabbitResourceSynchronization(RabbitResourceHolder resourceHolder,
java.lang.Object resourceKey,
boolean transacted) |
| Modifier and Type | Field and Description |
|---|---|
private RabbitResourceHolder |
BlockingQueueConsumer.resourceHolder |
| Modifier and Type | Field and Description |
|---|---|
private RabbitResourceHolder |
RabbitTransactionManager.RabbitTransactionObject.resourceHolder |
| Modifier and Type | Method and Description |
|---|---|
RabbitResourceHolder |
RabbitTransactionManager.RabbitTransactionObject.getResourceHolder() |
| Modifier and Type | Method and Description |
|---|---|
void |
RabbitTransactionManager.RabbitTransactionObject.setResourceHolder(RabbitResourceHolder resourceHolder) |