You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2017/06/01 18:20:02 UTC
[4/5] camel git commit: Polished
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 <da...@apache.org>
Authored: Thu Jun 1 19:44:42 2017 +0200
Committer: Claus Ibsen <da...@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