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; } }