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 <anco...@gmail.com> Authored: Thu Dec 1 08:35:38 2016 +0100 Committer: Andrea Cosentino <anco...@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;
