@@ -65,13 +65,6 @@ def connect_to_stick(self, callback=None) -> bool:
6565 self .connection = PlugwiseUSBConnection (self .port , self .parser .feed )
6666 if self .connection .connect ():
6767 _LOGGER .debug ("Starting message controller threads..." )
68- # receive timeout daemon
69- self ._run_receive_timeout_thread = True
70- self ._receive_timeout_thread = threading .Thread (
71- None , self ._receive_timeout_loop , "receive_timeout_thread" , (), {}
72- )
73- self ._receive_timeout_thread .daemon = True
74- self ._receive_timeout_thread .start ()
7568 # send daemon
7669 self ._send_message_queue = queue .Queue ()
7770 self ._run_send_message_thread = True
@@ -80,6 +73,13 @@ def connect_to_stick(self, callback=None) -> bool:
8073 )
8174 self ._send_message_thread .daemon = True
8275 self ._send_message_thread .start ()
76+ # receive timeout daemon
77+ self ._run_receive_timeout_thread = True
78+ self ._receive_timeout_thread = threading .Thread (
79+ None , self ._receive_timeout_loop , "receive_timeout_thread" , (), {}
80+ )
81+ self ._receive_timeout_thread .daemon = True
82+ self ._receive_timeout_thread .start ()
8383 _LOGGER .debug ("All message controller threads started" )
8484 else :
8585 _LOGGER .warning ("Failed to connect to USB stick" )
0 commit comments