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 <davscl...@apache.org> Authored: Sun Jun 12 16:30:24 2016 +0200 Committer: Claus Ibsen <davscl...@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);
