This is an automated email from the ASF dual-hosted git repository.

onders pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/master by this push:
     new d66ac62  Fix CS - camel-api
d66ac62 is described below

commit d66ac620486ff848433d6ef1bae9ec5af9161fc0
Author: onders <ond...@apache.org>
AuthorDate: Mon Dec 24 22:52:22 2018 +0300

    Fix CS - camel-api
---
 .../camel/spi/AsyncProcessorAwaitManager.java      |  3 +--
 .../java/org/apache/camel/spi/ProducerCache.java   |  4 ++--
 .../java/org/apache/camel/spi/RouteContext.java    |  2 +-
 .../org/apache/camel/support/ServiceSupport.java   | 24 +++++++++++-----------
 4 files changed, 16 insertions(+), 17 deletions(-)

diff --git 
a/camel-api/src/main/java/org/apache/camel/spi/AsyncProcessorAwaitManager.java 
b/camel-api/src/main/java/org/apache/camel/spi/AsyncProcessorAwaitManager.java
index dfcfdce..f2d9aae 100644
--- 
a/camel-api/src/main/java/org/apache/camel/spi/AsyncProcessorAwaitManager.java
+++ 
b/camel-api/src/main/java/org/apache/camel/spi/AsyncProcessorAwaitManager.java
@@ -17,7 +17,6 @@
 package org.apache.camel.spi;
 
 import java.util.Collection;
-import java.util.concurrent.CountDownLatch;
 
 import org.apache.camel.AsyncProcessor;
 import org.apache.camel.Exchange;
@@ -128,7 +127,7 @@ public interface AsyncProcessorAwaitManager extends 
StaticService {
      * @param processor the async processor to call
      * @param exchange the exchange to process
      */
-    void process(final AsyncProcessor processor, final Exchange exchange);
+    void process(AsyncProcessor processor, Exchange exchange);
 
     /**
      * Number of threads that are blocked waiting for other threads to trigger 
the callback when they are done processing
diff --git a/camel-api/src/main/java/org/apache/camel/spi/ProducerCache.java 
b/camel-api/src/main/java/org/apache/camel/spi/ProducerCache.java
index 51f7c8e..ab21835 100644
--- a/camel-api/src/main/java/org/apache/camel/spi/ProducerCache.java
+++ b/camel-api/src/main/java/org/apache/camel/spi/ProducerCache.java
@@ -24,7 +24,6 @@ import org.apache.camel.AsyncProducer;
 import org.apache.camel.Endpoint;
 import org.apache.camel.Exchange;
 import org.apache.camel.ExchangePattern;
-import org.apache.camel.PollingConsumer;
 import org.apache.camel.Processor;
 import org.apache.camel.Service;
 
@@ -36,7 +35,8 @@ public interface ProducerCache extends Service {
 
     Exchange send(Endpoint endpoint, Exchange exchange, Processor 
resultProcessor);
 
-    CompletableFuture<Exchange> asyncSendExchange(Endpoint endpoint, 
ExchangePattern pattern, Processor processor, Processor resultProcessor, 
Exchange inExchange, CompletableFuture<Exchange> exchangeFuture);
+    CompletableFuture<Exchange> asyncSendExchange(Endpoint endpoint, 
ExchangePattern pattern, 
+            Processor processor, Processor resultProcessor, Exchange 
inExchange, CompletableFuture<Exchange> exchangeFuture);
 
     Object getSource();
 
diff --git a/camel-api/src/main/java/org/apache/camel/spi/RouteContext.java 
b/camel-api/src/main/java/org/apache/camel/spi/RouteContext.java
index 8da17d4..d4bedc2 100644
--- a/camel-api/src/main/java/org/apache/camel/spi/RouteContext.java
+++ b/camel-api/src/main/java/org/apache/camel/spi/RouteContext.java
@@ -22,10 +22,10 @@ import java.util.Map;
 import org.apache.camel.CamelContext;
 import org.apache.camel.Endpoint;
 import org.apache.camel.EndpointAware;
-import org.apache.camel.meta.Experimental;
 import org.apache.camel.NamedNode;
 import org.apache.camel.Processor;
 import org.apache.camel.RuntimeConfiguration;
+import org.apache.camel.meta.Experimental;
 
 /**
  * The context used to activate new routing rules
diff --git 
a/camel-api/src/main/java/org/apache/camel/support/ServiceSupport.java 
b/camel-api/src/main/java/org/apache/camel/support/ServiceSupport.java
index cdc20a9..a6d52c1 100644
--- a/camel-api/src/main/java/org/apache/camel/support/ServiceSupport.java
+++ b/camel-api/src/main/java/org/apache/camel/support/ServiceSupport.java
@@ -217,18 +217,18 @@ public abstract class ServiceSupport implements 
StatefulService {
     @Override
     public ServiceStatus getStatus() {
         switch (status) {
-            case STARTING:
-                return ServiceStatus.Starting;
-            case STARTED:
-                return ServiceStatus.Started;
-            case SUSPENDING:
-                return ServiceStatus.Suspending;
-            case SUSPENDED:
-                return ServiceStatus.Suspended;
-            case STOPPING:
-                return ServiceStatus.Stopping;
-            default:
-                return ServiceStatus.Stopped;
+        case STARTING:
+            return ServiceStatus.Starting;
+        case STARTED:
+            return ServiceStatus.Started;
+        case SUSPENDING:
+            return ServiceStatus.Suspending;
+        case SUSPENDED:
+            return ServiceStatus.Suspended;
+        case STOPPING:
+            return ServiceStatus.Stopping;
+        default:
+            return ServiceStatus.Stopped;
         }
     }
 

Reply via email to