From e6e2e01951dc631116921b2abd80fdee77a2a5d5 Mon Sep 17 00:00:00 2001 From: Gary Russell Date: Sat, 21 Jan 2017 10:45:17 -0500 Subject: [PATCH] Polishing for Previous Commmit Container needs a queue. --- .../integration/amqp/outbound/OutboundEndpointTests.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) 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 b81d555944..2509b39ef1 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 @@ -93,8 +93,10 @@ public class OutboundEndpointTests { @Test public void testAsyncDelayExpression() { ConnectionFactory connectionFactory = mock(ConnectionFactory.class); + SimpleMessageListenerContainer container = new SimpleMessageListenerContainer(connectionFactory); + container.setQueueNames("foo"); AsyncRabbitTemplate amqpTemplate = spy(new AsyncRabbitTemplate(new RabbitTemplate(connectionFactory), - new SimpleMessageListenerContainer(connectionFactory), "replyTo")); + container, "replyTo")); amqpTemplate.setTaskScheduler(mock(TaskScheduler.class)); AsyncAmqpOutboundGateway gateway = new AsyncAmqpOutboundGateway(amqpTemplate); willAnswer(