Updated Branches: refs/heads/master ab4d4ee41 -> 9070abce0
CAMEL-6672 Fixed the issue of RabbitMQConsumer doesn't call the queueDeclare rightly Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/9070abce Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/9070abce Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/9070abce Branch: refs/heads/master Commit: 9070abce0bc87071cbedf5f148496618e04efe5b Parents: ab4d4ee Author: Willem Jiang <ningji...@apache.org> Authored: Tue Aug 27 14:53:43 2013 +0800 Committer: Willem Jiang <ningji...@apache.org> Committed: Tue Aug 27 15:00:49 2013 +0800 ---------------------------------------------------------------------- .../org/apache/camel/component/rabbitmq/RabbitMQConsumer.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/9070abce/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQConsumer.java ---------------------------------------------------------------------- diff --git a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQConsumer.java b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQConsumer.java index 7ae8d12..a1128dd 100644 --- a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQConsumer.java +++ b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQConsumer.java @@ -60,8 +60,9 @@ public class RabbitMQConsumer extends DefaultConsumer { endpoint.isDurable(), endpoint.isAutoDelete(), new HashMap<String, Object>()); - - channel.queueDeclare(endpoint.getQueue(), true, false, false, null); + + // need to make sure the queueDeclare is same with the exchange declare + channel.queueDeclare(endpoint.getQueue(), endpoint.isDurable(), false, endpoint.isAutoDelete(), null); channel.queueBind(endpoint.getQueue(), endpoint.getExchangeName(), endpoint.getRoutingKey() == null ? "" : endpoint.getRoutingKey());
