Polished
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/0d25645a Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/0d25645a Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/0d25645a Branch: refs/heads/master Commit: 0d25645a3cd7288e30aba178603bfec25f2a628e Parents: 413646a Author: Claus Ibsen <davscl...@apache.org> Authored: Thu Jun 1 19:44:42 2017 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Thu Jun 1 19:44:42 2017 +0200 ---------------------------------------------------------------------- .../apache/camel/management/mbean/ManagedSendProcessor.java | 1 - .../main/java/org/apache/camel/processor/SendProcessor.java | 7 +++---- 2 files changed, 3 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/0d25645a/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedSendProcessor.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedSendProcessor.java b/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedSendProcessor.java index 612abfa..4724220 100644 --- a/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedSendProcessor.java +++ b/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedSendProcessor.java @@ -92,7 +92,6 @@ public class ManagedSendProcessor extends ManagedProcessor implements ManagedSen TabularData answer = new TabularDataSupport(CamelOpenMBeanTypes.endpointsUtilizationTabularType()); // we only have 1 endpoint - CompositeType ct = CamelOpenMBeanTypes.endpointsUtilizationCompositeType(); String url = getDestination(); Long hits = processor.getCounter(); http://git-wip-us.apache.org/repos/asf/camel/blob/0d25645a/camel-core/src/main/java/org/apache/camel/processor/SendProcessor.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/processor/SendProcessor.java b/camel-core/src/main/java/org/apache/camel/processor/SendProcessor.java index 8f7c961..d933b59 100644 --- a/camel-core/src/main/java/org/apache/camel/processor/SendProcessor.java +++ b/camel-core/src/main/java/org/apache/camel/processor/SendProcessor.java @@ -143,10 +143,9 @@ public class SendProcessor extends ServiceSupport implements AsyncProcessor, Tra // record timing for sending the exchange using the producer final StopWatch watch = sw; - boolean sync = true; try { LOG.debug(">>>> {} {}", destination, exchange); - sync = producer.process(exchange, new AsyncCallback() { + return producer.process(exchange, new AsyncCallback() { @Override public void done(boolean doneSync) { try { @@ -164,10 +163,10 @@ public class SendProcessor extends ServiceSupport implements AsyncProcessor, Tra }); } catch (Throwable throwable) { exchange.setException(throwable); - callback.done(sync); + callback.done(true); } - return sync; + return true; } // send the exchange to the destination using the producer cache for the non optimized producers
