summaryrefslogtreecommitdiff
path: root/kafka/util.py
diff options
context:
space:
mode:
authorDana Powers <dana.powers@gmail.com>2015-03-02 17:49:07 -0800
committerDana Powers <dana.powers@gmail.com>2015-03-02 17:49:07 -0800
commite13eb0de8903541ec30050a8e7dd8a168752cea3 (patch)
treef36a86f711253155439cc71c07bf8f7859822d32 /kafka/util.py
parent7dea5599b64e6e59718b35eb2ce423c12b283799 (diff)
parent04979248afa82af77d02f76fbf12456bb83ae334 (diff)
downloadkafka-python-e13eb0de8903541ec30050a8e7dd8a168752cea3.tar.gz
Merge pull request #324 from chmduquesne/master
Properly destroying the objects that contain daemonized threads
Diffstat (limited to 'kafka/util.py')
-rw-r--r--kafka/util.py3
1 files changed, 3 insertions, 0 deletions
diff --git a/kafka/util.py b/kafka/util.py
index 14d2b2c..78c3607 100644
--- a/kafka/util.py
+++ b/kafka/util.py
@@ -151,3 +151,6 @@ class ReentrantTimer(object):
# noinspection PyAttributeOutsideInit
self.timer = None
self.fn = None
+
+ def __del__(self):
+ self.stop()