Spring/spring-amqp
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

RabbitTemplate: Use separate connection by default

Browse Source 
See: https://jira.spring.io/browse/AMQP-788
This commit is contained in:
Gary Russell
2018-05-11 12:16:32 -04:00
committed by Artem Bilan
parent 0fce70da1d
commit ca09dfa6d2
3 changed files with 10 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-rabbit/src/main/java/org/springframework/amqp/rabbit/core/RabbitTemplate.java
View File

@@ -244,7 +244,7 @@ public class RabbitTemplate extends RabbitAccessor implements BeanFactoryAware,
private boolean userCorrelationId;
private boolean usePublisherConnection;
private boolean usePublisherConnection = true;
/**
* Convenient constructor for use with setter injection. Don't forget to set the connection factory.

8
src/reference/asciidoc/amqp.adoc
View File

@@ -1069,12 +1069,12 @@ Examples:
The first example is a literal expression; the second obtains the `username` property from a connection factory bean in the application context.
[[separate-connection]]
===== Using a Separate Connection
===== Using a Separate Connection for RabbitTemplate and Consumers
Starting with _version 2.0.2_, set the `usePublisherConnection` property to `true` to use a different connection to that used by listener containers, when possible.
This is to avoid consumers being blocked when a producer is blocked for any reason.
The `CachingConnectionFactory` now maintains a second internal connection factory for this purpose.
Starting with _version 2.1_, the `RabbitTemplate` `usePublisherConnection` property is true by default to avoid consumers being blocked when a producer is blocked for any reason.
The `CachingConnectionFactory` maintains a second internal connection factory for this purpose.
If the rabbit template is running in a transaction started by the listener container, the container's channel is used, regardless of this setting.
To revert to the previous behavior of using the same connection as listener containers, set the template's property to `false`.
[[sending-messages]]
==== Sending messages

5
src/reference/asciidoc/whats-new.adoc
View File

@@ -18,3 +18,8 @@ RabbitMQ `ConnectionFactory` instances created by the `RabbitConnectionFactoryBe
Certain classes have moved to different packages; most are internal classes and won't affect user applications.
Two exceptions are `ChannelAwareMessageListener` and `RabbitListenerErrorHandler`; these interfaces are now in `org.springframework.amqp.rabbit.listener.api`.
===== RabbitTemplate Changes
The `RabbitTemplate` now sets `usePublisherConnection` to `true` by default.
See <<separate-connection>> for more information.