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 2015/12/30 17:05:10 UTC
[3/4] camel git commit: ZooKeeperProducer does not stop ZooKeeper
threads if Camel context ist stopped. Added overloaded doStop() method to
shutdown ZooKeeperConnectionManager
ZooKeeperProducer does not stop ZooKeeper threads if Camel context ist stopped. Added overloaded doStop() method to shutdown ZooKeeperConnectionManager
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/3eee448b
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/3eee448b
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/3eee448b
Branch: refs/heads/camel-2.16.x
Commit: 3eee448bc384491864a5ea53b206a9a3816077fe
Parents: 5c4f008
Author: Klaus Schröder <kl...@next-audience.com>
Authored: Thu Dec 19 14:13:16 2013 +0100
Committer: Claus Ibsen <da...@apache.org>
Committed: Wed Dec 30 17:04:52 2015 +0100
----------------------------------------------------------------------
.../apache/camel/component/zookeeper/ZookeeperProducer.java | 9 +++++++++
1 file changed, 9 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/3eee448b/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/ZookeeperProducer.java
----------------------------------------------------------------------
diff --git a/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/ZookeeperProducer.java b/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/ZookeeperProducer.java
index d147b4f..aaf368b 100644
--- a/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/ZookeeperProducer.java
+++ b/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/ZookeeperProducer.java
@@ -119,6 +119,15 @@ public class ZookeeperProducer extends DefaultProducer {
}
}
+ @Override
+ protected void doStop() throws Exception {
+ super.doStop();
+ if (log.isTraceEnabled()) {
+ log.trace(String.format("Shutting down zookeeper producer of '%s'", configuration.getPath()));
+ }
+ zkm.shutdown();
+ }
+
private void asynchronouslyDeleteNode(ZooKeeper connection, ProductionContext context) {
if (log.isDebugEnabled()) {
log.debug(format("Deleting node '%s', not waiting for confirmation", context.node));