camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject [2/3] camel git commit: Transfer shutdown to component as the workerPool might be shared between several producer
Date Wed, 07 Sep 2016 07:45:07 GMT
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/17659a78
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/17659a78
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/17659a78

Branch: refs/heads/master
Commit: 17659a7875e5124a2b619b31f55941d280dab681
Parents: 26041ca
Author: Jean-Yves BESSON <jean-yves.besson@external.partecis.eu>
Authored: Mon Sep 5 11:08:13 2016 +0200
Committer: Claus Ibsen <davsclaus@apache.org>
Committed: Wed Sep 7 09:44:57 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/17659a78/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();
     }
 


Mime
View raw message