Fixed CS. This closes #928.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/9d8f0c20 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/9d8f0c20 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/9d8f0c20 Branch: refs/heads/camel-2.17.x Commit: 9d8f0c200d2085c961bf72d0b29545bb555fc0dd Parents: 1c710c4 Author: Claus Ibsen <davscl...@apache.org> Authored: Wed Apr 6 07:21:13 2016 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Wed Apr 6 07:25:23 2016 +0200 ---------------------------------------------------------------------- .../camel/component/rabbitmq/RabbitMQDeclareSupport.java | 6 +++--- .../org/apache/camel/component/rabbitmq/RabbitMQEndpoint.java | 1 - 2 files changed, 3 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/9d8f0c20/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQDeclareSupport.java ---------------------------------------------------------------------- diff --git a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQDeclareSupport.java b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQDeclareSupport.java index 2539d50..5b17370 100644 --- a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQDeclareSupport.java +++ b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQDeclareSupport.java @@ -45,9 +45,9 @@ public class RabbitMQDeclareSupport { } private void declareAndBindExchangeWithQueue(final Channel channel) throws IOException { - if(shouldDeclareExchange()){ - declareExchange(channel, endpoint.getExchangeName(), endpoint.getExchangeType(), resolvedExchangeArguments()); - } + if (shouldDeclareExchange()) { + declareExchange(channel, endpoint.getExchangeName(), endpoint.getExchangeType(), resolvedExchangeArguments()); + } if (shouldDeclareQueue()) { // need to make sure the queueDeclare is same with the exchange declare http://git-wip-us.apache.org/repos/asf/camel/blob/9d8f0c20/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQEndpoint.java ---------------------------------------------------------------------- diff --git a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQEndpoint.java b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQEndpoint.java index 4293ca7..71721cf 100644 --- a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQEndpoint.java +++ b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQEndpoint.java @@ -407,7 +407,6 @@ public class RabbitMQEndpoint extends DefaultEndpoint { } /** - * If true the producer will not declare the exchange. * This can be used if we need to declare the queue but not the exchange */ public void setSkipExchangeDeclare(boolean skipExchangeDeclare) {
