diff --git a/spring-amqp-parent/pom.xml b/spring-amqp-parent/pom.xml index deeeecc2..1ac1d022 100644 --- a/spring-amqp-parent/pom.xml +++ b/spring-amqp-parent/pom.xml @@ -19,7 +19,7 @@ 1.5.10 1.4.3 1.5.3 - 1.8.1 + 2.0.0 3.0.3.RELEASE diff --git a/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/core/RabbitTemplate.java b/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/core/RabbitTemplate.java index cd9c5c26..da6404c3 100644 --- a/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/core/RabbitTemplate.java +++ b/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/core/RabbitTemplate.java @@ -301,7 +301,7 @@ public class RabbitTemplate extends RabbitAccessor implements RabbitOperations { } } }; - channel.basicConsume(replyToAddress.getRoutingKey(), noAck, consumerTag, noLocal, exclusive, consumer); + channel.basicConsume(replyToAddress.getRoutingKey(), noAck, consumerTag, noLocal, exclusive, null, consumer); // TODO: get exchange and routing key from method args // methods that are higher in the stack can determine whether to fallback to template properties doSend(channel, exchange, routingKey, message);