From 3530e764229973c273134090eba22ccef300bf79 Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Wed, 31 Jan 2018 12:18:14 -0500 Subject: [PATCH] INT-4030: Do not cache consumers in the JMS tests JIRA: https://jira.spring.io/browse/INT-4030 **Cherry-pick to 4.3.x** --- .../integration/jms/JmsOutboundGatewayTests.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/spring-integration-jms/src/test/java/org/springframework/integration/jms/JmsOutboundGatewayTests.java b/spring-integration-jms/src/test/java/org/springframework/integration/jms/JmsOutboundGatewayTests.java index 6bb61f3c2f..981f3065ad 100644 --- a/spring-integration-jms/src/test/java/org/springframework/integration/jms/JmsOutboundGatewayTests.java +++ b/spring-integration-jms/src/test/java/org/springframework/integration/jms/JmsOutboundGatewayTests.java @@ -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("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("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();