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 2016/06/12 14:32:27 UTC
[4/4] camel git commit: Fixed CS. This closes #1026
Fixed CS. This closes #1026
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/cf939a69
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/cf939a69
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/cf939a69
Branch: refs/heads/camel-2.17.x
Commit: cf939a6927dd28882046a03fb32c5b45e5ff2054
Parents: eed88d1
Author: Claus Ibsen <da...@apache.org>
Authored: Sun Jun 12 16:30:24 2016 +0200
Committer: Claus Ibsen <da...@apache.org>
Committed: Sun Jun 12 16:32:02 2016 +0200
----------------------------------------------------------------------
.../java/org/apache/camel/component/netty4/NettyProducer.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/cf939a69/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/NettyProducer.java
----------------------------------------------------------------------
diff --git a/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/NettyProducer.java b/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/NettyProducer.java
index 4bdc121..a1b8d7f 100644
--- a/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/NettyProducer.java
+++ b/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/NettyProducer.java
@@ -280,7 +280,9 @@ public class NettyProducer extends DefaultAsyncProducer {
final Channel channel = existing;
final AsyncCallback producerCallback;
- if(configuration.isReuseChannel()) {
+ if (configuration.isReuseChannel()) {
+ // use callback as-is because we should not put it back in the pool as NettyProducerCallback would do
+ // as when reuse channel is enabled it will put the channel back in the pool when exchange is done using on completion
producerCallback = callback;
} else {
producerCallback = new NettyProducerCallback(channel, callback);