Assign names to heartbeat and receiver threads

jasonrbriggs · Jan 24, 2016 · 2cc5b78 · 2cc5b78
1 parent 4058051
commit 2cc5b78
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/stomp/listener.py b/stomp/listener.py
@@ -188,6 +188,7 @@ def on_connected(self, headers, body):
                 self.running = True
                 if self.heartbeat_thread is None:
                     self.heartbeat_thread = utils.default_create_thread(self.__heartbeat_loop)
+                    self.heartbeat_thread.name = "StompHeartbeat%s" % getattr(self.heartbeat_thread, "name", "Thread")
 
     def on_disconnected(self):
         self.running = False

diff --git a/stomp/transport.py b/stomp/transport.py
@@ -108,7 +108,8 @@ def start(self):
         """
         self.running = True
         self.attempt_connection()
-        self.create_thread_fc(self.__receiver_loop)
+        receiver_thread = self.create_thread_fc(self.__receiver_loop)
+        receiver_thread.name = "StompReceiver%s" % getattr(receiver_thread, "name", "Thread")
         self.notify('connecting')
 
     def stop(self):