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/b86e52d0 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/b86e52d0 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/b86e52d0 Branch: refs/heads/master Commit: b86e52d0a6e5b5d6095727346594978ea2a15cf7 Parents: 27f6cdb 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:23:47 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/b86e52d0/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/b86e52d0/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) {
