Fix to allow pulsar to shutdown cleanly again.

pulsar/managers/queued.py

@@ -41,6 +41,7 @@ class QueueManager(Manager):
         self.work_threads = []
         for i in range(num_concurrent_jobs):
             worker = threading.Thread(target=self.run_next)
+            worker.daemon = True
             worker.start()
             self.work_threads.append(worker)
 

pulsar/messaging/bind_amqp.py

@@ -71,7 +71,9 @@ def __start_consumer(name, exchange, target):
     exchange_url = mask_password_from_url(exchange.url)
     thread_name = "consume-%s-%s" % (name, exchange_url)
     thread = threading.Thread(name=thread_name, target=target)
-    thread.daemon = False
+    # TODO: If the shutdown code is actually called make this
+    # not a daemon.
+    thread.daemon = True
     thread.start()
     return thread