python/mqtt
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

change Queue -> queue (py2->py3)

Browse Source
This commit is contained in:
tkl 2019-08-14 13:37:49 +00:00
parent da1495d642
commit 5d83bf7dc4
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
mqtt/__init__.py
View File

@ -3,7 +3,7 @@ Created on Dec 19, 2016
@author: klaehn @author: klaehn
''' '''
import Queue import queue
import threading import threading
import time import time
import paho.mqtt.client as mqtt_client import paho.mqtt.client as mqtt_client
@ -32,7 +32,7 @@ class Mqtt(object):
self.qos = qos self.qos = qos
self.retain = retain self.retain = retain
self.subscribe = subscribe self.subscribe = subscribe
self.receive_queue = Queue.Queue() self.receive_queue = queue.Queue()
self.rx_sema = threading.Semaphore(0) self.rx_sema = threading.Semaphore(0)
def connect(self): def connect(self):