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

INT-4030: Do not cache consumers in the JMS tests

Browse Source 
JIRA: https://jira.spring.io/browse/INT-4030

**Cherry-pick to 4.3.x**
This commit is contained in:
Artem Bilan
2018-01-31 12:18:14 -05:00
parent 30fac62c2c
commit 3530e76422
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
spring-integration-jms/src/test/java/org/springframework/integration/jms/JmsOutboundGatewayTests.java
View File

@@ -167,6 +167,7 @@ public class JmsOutboundGatewayTests extends ActiveMQMultiContextTests {
public void testConnectionBreakOnReplyMessageIdCorrelation() throws Exception {
CachingConnectionFactory connectionFactory1 = new CachingConnectionFactory(
new ActiveMQConnectionFactory("vm://localhost?broker.persistent=false"));
connectionFactory1.setCacheConsumers(false);
final JmsOutboundGateway gateway = new JmsOutboundGateway();
gateway.setConnectionFactory(connectionFactory1);
String requestQ = "requests1";
@@ -183,6 +184,7 @@ public class JmsOutboundGatewayTests extends ActiveMQMultiContextTests {
exec.execute(() -> gateway.handleMessage(new GenericMessage<String>("foo")));
CachingConnectionFactory connectionFactory2 = new CachingConnectionFactory(
new ActiveMQConnectionFactory("vm://localhost?broker.persistent=false"));
connectionFactory2.setCacheConsumers(false);
JmsTemplate template = new JmsTemplate(connectionFactory2);
template.setReceiveTimeout(10000);
template.afterPropertiesSet();
@@ -208,6 +210,7 @@ public class JmsOutboundGatewayTests extends ActiveMQMultiContextTests {
public void testConnectionBreakOnReplyCustomCorrelation() throws Exception {
CachingConnectionFactory connectionFactory1 = new CachingConnectionFactory(
new ActiveMQConnectionFactory("vm://localhost?broker.persistent=false"));
connectionFactory1.setCacheConsumers(false);
final JmsOutboundGateway gateway = new JmsOutboundGateway();
gateway.setConnectionFactory(connectionFactory1);
String requestQ = "requests2";
@@ -225,6 +228,7 @@ public class JmsOutboundGatewayTests extends ActiveMQMultiContextTests {
exec.execute(() -> gateway.handleMessage(new GenericMessage<String>("foo")));
CachingConnectionFactory connectionFactory2 = new CachingConnectionFactory(
new ActiveMQConnectionFactory("vm://localhost?broker.persistent=false"));
connectionFactory2.setCacheConsumers(false);
JmsTemplate template = new JmsTemplate(connectionFactory2);
template.setReceiveTimeout(10000);
template.afterPropertiesSet();