diff --git a/spring-integration-amqp/src/test/java/org/springframework/integration/amqp/outbound/OutboundEndpointTests.java b/spring-integration-amqp/src/test/java/org/springframework/integration/amqp/outbound/OutboundEndpointTests.java index 0200f4c2f6..cd737892cc 100644 --- a/spring-integration-amqp/src/test/java/org/springframework/integration/amqp/outbound/OutboundEndpointTests.java +++ b/spring-integration-amqp/src/test/java/org/springframework/integration/amqp/outbound/OutboundEndpointTests.java @@ -134,6 +134,7 @@ public class OutboundEndpointTests { public void testHeaderMapperWinsGateway() { ConnectionFactory connectionFactory = mock(ConnectionFactory.class); TestRabbitTemplate amqpTemplate = spy(new TestRabbitTemplate(connectionFactory)); + amqpTemplate.setUseTemporaryReplyQueues(true); AmqpOutboundEndpoint endpoint = new AmqpOutboundEndpoint(amqpTemplate); endpoint.setHeadersMappedLast(true); endpoint.setExpectReply(true);