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 de18110ef1..bec50c38c0 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
@@ -172,6 +172,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";
@@ -188,6 +189,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();
@@ -218,6 +220,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";
@@ -235,6 +238,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();