camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject [4/4] camel git commit: Fixed CS. This closes #928.
Date Wed, 06 Apr 2016 05:25:35 GMT
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 <davsclaus@apache.org>
Authored: Wed Apr 6 07:21:13 2016 +0200
Committer: Claus Ibsen <davsclaus@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) {


Mime
View raw message