diff --git a/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/annotation/EnableRabbitIntegrationTests.java b/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/annotation/EnableRabbitIntegrationTests.java index 48d28d21..e3133daa 100644 --- a/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/annotation/EnableRabbitIntegrationTests.java +++ b/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/annotation/EnableRabbitIntegrationTests.java @@ -214,7 +214,7 @@ public class EnableRabbitIntegrationTests { @Test public void autoDeclare() { - assertEquals("FOO", rabbitTemplate.convertSendAndReceive("auto.exch", "auto.rk", "foo")); + assertEquals("FOOthreadNamer-1", rabbitTemplate.convertSendAndReceive("auto.exch", "auto.rk", "foo")); } @Test @@ -660,13 +660,13 @@ public class EnableRabbitIntegrationTests { public static class MyService { - @RabbitListener(bindings = @QueueBinding( + @RabbitListener(id = "threadNamer", bindings = @QueueBinding( value = @Queue(value = "auto.declare", autoDelete = "true"), exchange = @Exchange(value = "auto.exch", autoDelete = "true"), key = "auto.rk") ) public String handleWithDeclare(String foo) { - return foo.toUpperCase(); + return foo.toUpperCase() + Thread.currentThread().getName(); } @RabbitListener(bindings = @QueueBinding(