diff --git a/spring-integration-jms/src/test/java/org/springframework/integration/jms/JmsInboundChannelAdapterTests.java b/spring-integration-jms/src/test/java/org/springframework/integration/jms/JmsInboundChannelAdapterTests.java index 6364e1d041..bd1f4d4b73 100644 --- a/spring-integration-jms/src/test/java/org/springframework/integration/jms/JmsInboundChannelAdapterTests.java +++ b/spring-integration-jms/src/test/java/org/springframework/integration/jms/JmsInboundChannelAdapterTests.java @@ -51,7 +51,7 @@ public class JmsInboundChannelAdapterTests extends ActiveMQMultiContextTests { public void testTransactionalReceive() { JmsTemplate template = new JmsTemplate(connectionFactory); template.convertAndSend("foo", "bar"); - assertNotNull(out.receive(2000)); + assertNotNull(out.receive(20000)); /* * INT-3288 - previously acknowledge="transacted" * Caused by: javax.jms.JMSException: acknowledgeMode SESSION_TRANSACTED cannot be used for an non-transacted Session diff --git a/spring-integration-jms/src/test/java/org/springframework/integration/jms/JmsOutboundChannelAdapterTests.java b/spring-integration-jms/src/test/java/org/springframework/integration/jms/JmsOutboundChannelAdapterTests.java index 1eda51e267..3338c6301f 100644 --- a/spring-integration-jms/src/test/java/org/springframework/integration/jms/JmsOutboundChannelAdapterTests.java +++ b/spring-integration-jms/src/test/java/org/springframework/integration/jms/JmsOutboundChannelAdapterTests.java @@ -57,11 +57,12 @@ public class JmsOutboundChannelAdapterTests extends ActiveMQMultiContextTests { public void testTransactionalSend() { JmsTemplate template = new JmsTemplate(connectionFactory); template.convertAndSend("foo", "Hello, world!"); - template.setReceiveTimeout(1000); + template.setReceiveTimeout(20000); assertNotNull(template.receive("bar")); this.aborter.abort = true; template.convertAndSend("foo", "Hello, world!"); + template.setReceiveTimeout(1000); assertNull(template.receive("bar")); endpoint.stop(); }