From b62900b6219bbea8afa0c1f24685b46d3540e4ed Mon Sep 17 00:00:00 2001
From: sideshowdave7
Date: Wed, 18 Jan 2017 20:54:04 -0700
Subject: close request queue and block until its flushed

---
 eventmq/jobmanager.py | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/eventmq/jobmanager.py b/eventmq/jobmanager.py
index b6de15e..1f540c1 100644
--- a/eventmq/jobmanager.py
+++ b/eventmq/jobmanager.py
@@ -126,8 +126,11 @@ class JobManager(HeartbeatMixin, EMQPService):
         while True:
             # Clear any workers if it's time to shut down
             if self.received_disconnect:
-                for w in self.workers:
+                for _ in xrange(0, len(self.workers)):
+                    logger.debug('Requesting worker death...')
                     self.request_queue.put_nowait('DONE')
+                self.request_queue.close()
+                self.request_queue.join_thread()
                 break
 
             events = self.poller.poll()
-- 
cgit v1.2.1