Spring/spring-amqp
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

AMQP-57 updated Rabbit client version from 1.8.1 to 2.0.0. This required one change in RabbitTemplate due to a change in the Channel.basicConsume() method we were using

Browse Source
This commit is contained in:
Mark Fisher
2010-08-27 13:25:03 -04:00
parent dd11df4b59
commit 74e6c05d77
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-amqp-parent/pom.xml
View File

@@ -19,7 +19,7 @@
<org.slf4j.version>1.5.10</org.slf4j.version>
<org.codehaus.jackson.version>1.4.3</org.codehaus.jackson.version>
<org.erlang.otp.version>1.5.3</org.erlang.otp.version>
<com.rabbitmq.version>1.8.1</com.rabbitmq.version>
<com.rabbitmq.version>2.0.0</com.rabbitmq.version>
<org.springframework.version>3.0.3.RELEASE</org.springframework.version>
</properties>
<profiles>

2
spring-rabbit/src/main/java/org/springframework/amqp/rabbit/core/RabbitTemplate.java
View File

@@ -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);