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 <[email protected]>
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;
}
}