
     i3                     J    d dl mZ d dlmZ d dlZd dlZd dlZ G d de      Zy)    )BaseCommand)start_mqtt_clientNc                       e Zd ZdZd Zy)CommandzStart MQTT clientc                 T   dd l }dd l}t               a	 	  |j                  d       # t
        $ rv t        d       t        r(t        j                          t        j                          d}|j                  j                  |      r |j                  |       t        d       Y y w xY w)Nr      z
Exiting...z/tmp/mqtt_client.lockzMQTT client stopped)ostimer   clientsleepKeyboardInterruptprint	loop_stop
disconnectpathexistsremove)selfargskwargsr	   r
   	lock_files         a/home/devuser/fomin/mqttuser/mqtt_project/mqtt_processor/management/commands/start_mqtt_client.pyhandlezCommand.handle   s    "$	)

1   		),  "!!#/Iww~~i(		)$'(		)s   ( A<B'&B'N)__name__
__module____qualname__helpr        r   r   r      s    D)r   r   )django.core.management.baser   mqtt_processor.mqtt_clientr   r	   r
   r   r   r   r   <module>r"      s"    3 8 	  )k )r   