delete heartbeat queue on disconnect

Author: ToGoBananas

moleculer/client.py

@@ -142,9 +142,11 @@ def create_topics(self):
 
         for queue_type, queue_name in queues:
             if queue_type in ('REQUEST', 'RESPONSE'):
-                self.setup_queue(queue_name, ttl=False)
+                self.setup_queue(queue_name, ttl=False, auto_delete=False)
+            elif queue_type == 'HEARTBEAT':
+                self.setup_queue(queue_name, ttl=True, auto_delete=True)
             else:
-                self.setup_queue(queue_name, ttl=True)
+                self.setup_queue(queue_name, ttl=True, auto_delete=False)
         for exchange_type, exchange_name in MOLECULER_EXCHANGES.items():
             self.setup_exchange(exchange_name)
 
@@ -225,11 +227,12 @@ def on_exchange_declareok(self, unused_frame):
         LOGGER.info('Exchange declared')
         self.ready_topics.append(None)
 
-    def setup_queue(self, queue_name, ttl=True):
+    def setup_queue(self, queue_name, ttl=True, auto_delete=False):
         """Setup the queue on RabbitMQ by invoking the Queue.Declare RPC
         command. When it is complete, the on_queue_declareok method will
         be invoked by pika.
 
+        :param auto_delete:
         :param ttl:
         :param str|unicode queue_name: The name of the queue to declare.
 
@@ -238,7 +241,7 @@ def setup_queue(self, queue_name, ttl=True):
         arguments = {}
         if ttl:
             arguments['x-message-ttl'] = 5000  # eventTimeToLive: https://github.com/ice-services/moleculer/pull/72
-        self._channel.queue_declare(self.on_queue_declareok, queue_name, arguments=arguments)
+        self._channel.queue_declare(self.on_queue_declareok, queue_name, auto_delete=auto_delete, arguments=arguments)
 
     def on_queue_declareok(self, method_frame):
         """Method invoked by pika when the Queue.Declare RPC call made in