camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From acosent...@apache.org
Subject [2/2] camel git commit: Fixed CS
Date Thu, 01 Dec 2016 07:36:31 GMT
Fixed CS


Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/2310011d
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/2310011d
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/2310011d

Branch: refs/heads/master
Commit: 2310011d14074ab4f2a9a165c9e5c6181ba531dd
Parents: dc2138a
Author: Andrea Cosentino <ancosen@gmail.com>
Authored: Thu Dec 1 08:35:38 2016 +0100
Committer: Andrea Cosentino <ancosen@gmail.com>
Committed: Thu Dec 1 08:35:38 2016 +0100

----------------------------------------------------------------------
 .../component/google/pubsub/GooglePubsubConnectionFactory.java   | 2 +-
 .../camel/component/google/pubsub/GooglePubsubConsumer.java      | 2 +-
 .../camel/component/google/pubsub/GooglePubsubEndpoint.java      | 2 +-
 .../component/google/pubsub/consumer/ExchangeAckTransaction.java | 4 ++--
 .../component/google/pubsub/consumer/PubsubAcknowledgement.java  | 4 ++--
 5 files changed, 7 insertions(+), 7 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/2310011d/components/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/GooglePubsubConnectionFactory.java
----------------------------------------------------------------------
diff --git a/components/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/GooglePubsubConnectionFactory.java
b/components/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/GooglePubsubConnectionFactory.java
index 59bdb8b..2762451 100644
--- a/components/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/GooglePubsubConnectionFactory.java
+++ b/components/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/GooglePubsubConnectionFactory.java
@@ -65,7 +65,7 @@ public class GooglePubsubConnectionFactory {
 
     public Pubsub getMultiThreadClient(int parallelThreads) throws Exception {
 
-        PoolingHttpClientConnectionManager cm=new PoolingHttpClientConnectionManager();
+        PoolingHttpClientConnectionManager cm = new PoolingHttpClientConnectionManager();
         cm.setDefaultMaxPerRoute(parallelThreads);
         cm.setMaxTotal(parallelThreads);
         CloseableHttpClient httpClient = HttpClients.createMinimal(cm);

http://git-wip-us.apache.org/repos/asf/camel/blob/2310011d/components/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/GooglePubsubConsumer.java
----------------------------------------------------------------------
diff --git a/components/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/GooglePubsubConsumer.java
b/components/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/GooglePubsubConsumer.java
index dffc63c..f056bbd 100644
--- a/components/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/GooglePubsubConsumer.java
+++ b/components/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/GooglePubsubConsumer.java
@@ -6,7 +6,7 @@
  * (the "License"); you may not use this file except in compliance with
  * the License.  You may obtain a copy of the License at
  *
- * http://www.apache.org/licenses/LICENSE-2.0
+ *      http://www.apache.org/licenses/LICENSE-2.0
  *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,

http://git-wip-us.apache.org/repos/asf/camel/blob/2310011d/components/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/GooglePubsubEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/GooglePubsubEndpoint.java
b/components/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/GooglePubsubEndpoint.java
index 03c7b93..162cc1c 100644
--- a/components/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/GooglePubsubEndpoint.java
+++ b/components/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/GooglePubsubEndpoint.java
@@ -6,7 +6,7 @@
  * (the "License"); you may not use this file except in compliance with
  * the License.  You may obtain a copy of the License at
  *
- * http://www.apache.org/licenses/LICENSE-2.0
+ *      http://www.apache.org/licenses/LICENSE-2.0
  *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,

http://git-wip-us.apache.org/repos/asf/camel/blob/2310011d/components/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/consumer/ExchangeAckTransaction.java
----------------------------------------------------------------------
diff --git a/components/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/consumer/ExchangeAckTransaction.java
b/components/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/consumer/ExchangeAckTransaction.java
index b807496..76dabbd 100644
--- a/components/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/consumer/ExchangeAckTransaction.java
+++ b/components/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/consumer/ExchangeAckTransaction.java
@@ -41,11 +41,11 @@ public class ExchangeAckTransaction extends PubsubAcknowledgement implements
Syn
         Integer deadline = 0;
         Object configuredDeadline = exchange.getIn().getHeader(GooglePubsubConstants.ACK_DEADLINE);
 
-        if ( configuredDeadline != null && Integer.class.isInstance(configuredDeadline)
) {
+        if (configuredDeadline != null && Integer.class.isInstance(configuredDeadline))
{
             deadline = (Integer) configuredDeadline;
         }
 
-        if ( configuredDeadline != null && String.class.isInstance(configuredDeadline)
) {
+        if (configuredDeadline != null && String.class.isInstance(configuredDeadline))
{
             try {
                 deadline = Integer.valueOf((String) configuredDeadline);
             } catch (Exception e) {

http://git-wip-us.apache.org/repos/asf/camel/blob/2310011d/components/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/consumer/PubsubAcknowledgement.java
----------------------------------------------------------------------
diff --git a/components/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/consumer/PubsubAcknowledgement.java
b/components/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/consumer/PubsubAcknowledgement.java
index 267abc0..2fc8174 100644
--- a/components/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/consumer/PubsubAcknowledgement.java
+++ b/components/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/consumer/PubsubAcknowledgement.java
@@ -28,11 +28,11 @@ import org.slf4j.LoggerFactory;
 
 public abstract class PubsubAcknowledgement {
 
+    protected Logger logger;
+    
     private final String subscriptionFullName;
     private final GooglePubsubEndpoint endpoint;
 
-    protected Logger logger;
-
     public PubsubAcknowledgement(GooglePubsubEndpoint endpoint) {
         super();
         this.endpoint = endpoint;


Mime
View raw message