You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ni...@apache.org on 2013/08/02 12:49:27 UTC
git commit: CAMEL-6597 polish the code of CamelOutputStream
Updated Branches:
refs/heads/master 809fbab39 -> f1c877a6e
CAMEL-6597 polish the code of CamelOutputStream
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/f1c877a6
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/f1c877a6
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/f1c877a6
Branch: refs/heads/master
Commit: f1c877a6e1e2eb59565f982d005cc422a839f4c3
Parents: 809fbab
Author: Willem Jiang <ni...@apache.org>
Authored: Fri Aug 2 16:20:45 2013 +0800
Committer: Willem Jiang <ni...@apache.org>
Committed: Fri Aug 2 18:48:39 2013 +0800
----------------------------------------------------------------------
.../component/cxf/transport/CamelOutputStream.java | 14 ++++----------
1 file changed, 4 insertions(+), 10 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/f1c877a6/components/camel-cxf-transport/src/main/java/org/apache/camel/component/cxf/transport/CamelOutputStream.java
----------------------------------------------------------------------
diff --git a/components/camel-cxf-transport/src/main/java/org/apache/camel/component/cxf/transport/CamelOutputStream.java b/components/camel-cxf-transport/src/main/java/org/apache/camel/component/cxf/transport/CamelOutputStream.java
index 6cc1bb1..b00f472 100644
--- a/components/camel-cxf-transport/src/main/java/org/apache/camel/component/cxf/transport/CamelOutputStream.java
+++ b/components/camel-cxf-transport/src/main/java/org/apache/camel/component/cxf/transport/CamelOutputStream.java
@@ -145,19 +145,13 @@ class CamelOutputStream extends CachedOutputStream {
try {
Executor ex = outMessage.getExchange().get(Executor.class);
if (ex != null) {
- final Executor ex2 = ex;
- final Runnable origRunnable = runnable;
- runnable = new Runnable() {
- public void run() {
- outMessage.getExchange().put(Executor.class.getName()
- + ".USING_SPECIFIED", Boolean.TRUE);
- ex2.execute(origRunnable);
- }
- };
+ outMessage.getExchange().put(Executor.class.getName()
+ + ".USING_SPECIFIED", Boolean.TRUE);
+ ex.execute(runnable);
} else {
WorkQueueManager mgr = outMessage.getExchange().get(Bus.class)
.getExtension(WorkQueueManager.class);
- AutomaticWorkQueue qu = mgr.getNamedWorkQueue("nmr-conduit");
+ AutomaticWorkQueue qu = mgr.getNamedWorkQueue("camel-cxf-conduit");
if (qu == null) {
qu = mgr.getAutomaticWorkQueue();
}