Fixed CS
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/d57797c3 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/d57797c3 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/d57797c3 Branch: refs/heads/master Commit: d57797c33adc4119268adcc2efaaa93d3927d522 Parents: ade4270 Author: Andrea Cosentino <anco...@gmail.com> Authored: Tue Jul 26 13:19:25 2016 +0200 Committer: Andrea Cosentino <anco...@gmail.com> Committed: Tue Jul 26 13:19:41 2016 +0200 ---------------------------------------------------------------------- .../camel/component/rabbitmq/RabbitMQDeclareSupport.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/d57797c3/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 7ccb6a6..f22592d 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 @@ -87,8 +87,8 @@ public class RabbitMQDeclareSupport { return !endpoint.isSkipExchangeDeclare(); } - private boolean shouldBindQueue(){ - return !endpoint.isSkipQueueBind(); + private boolean shouldBindQueue() { + return !endpoint.isSkipQueueBind(); } private void populateQueueArgumentsFromConfigurer(final Map<String, Object> queueArgs) { @@ -104,9 +104,9 @@ public class RabbitMQDeclareSupport { private void declareAndBindQueue(final Channel channel, final String queue, final String exchange, final String routingKey, final Map<String, Object> arguments) throws IOException { channel.queueDeclare(queue, endpoint.isDurable(), false, endpoint.isAutoDelete(), arguments); - if(shouldBindQueue()){ - channel.queueBind(queue, exchange, emptyIfNull(routingKey)); - } + if(shouldBindQueue()){ + channel.queueBind(queue, exchange, emptyIfNull(routingKey)); + } } private String emptyIfNull(final String routingKey) {
