Repository: camel Updated Branches: refs/heads/ftpfix [created] 9ffbfc489
Transfer shutdown to component as the workerPool might be shared between several producer Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/2e1dd68e Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/2e1dd68e Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/2e1dd68e Branch: refs/heads/ftpfix Commit: 2e1dd68e09efa937121bee6200466bdf0abcadbc Parents: dfb1083 Author: Jean-Yves BESSON <jean-yves.bes...@external.partecis.eu> Authored: Mon Sep 5 11:08:13 2016 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Wed Sep 7 09:21:32 2016 +0200 ---------------------------------------------------------------------- .../java/org/apache/camel/component/netty4/NettyComponent.java | 5 +++++ 1 file changed, 5 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/2e1dd68e/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/NettyComponent.java ---------------------------------------------------------------------- diff --git a/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/NettyComponent.java b/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/NettyComponent.java index 601f952..33b814e 100644 --- a/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/NettyComponent.java +++ b/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/NettyComponent.java @@ -157,6 +157,11 @@ public class NettyComponent extends UriEndpointComponent { executorService = null; } + //shutdown workerPool if configured + if (configuration.getWorkerGroup() != null) { + configuration.getWorkerGroup().shutdownGracefully(); + } + super.doStop(); }
