From 5d83bf7dc4fa5a37093dd9e877968215c7fdfb4c Mon Sep 17 00:00:00 2001 From: tkl Date: Wed, 14 Aug 2019 13:37:49 +0000 Subject: [PATCH] change Queue -> queue (py2->py3) --- mqtt/__init__.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/mqtt/__init__.py b/mqtt/__init__.py index fd7dbfd..2562800 100644 --- a/mqtt/__init__.py +++ b/mqtt/__init__.py @@ -3,7 +3,7 @@ Created on Dec 19, 2016 @author: klaehn ''' -import Queue +import queue import threading import time import paho.mqtt.client as mqtt_client @@ -32,7 +32,7 @@ class Mqtt(object): self.qos = qos self.retain = retain self.subscribe = subscribe - self.receive_queue = Queue.Queue() + self.receive_queue = queue.Queue() self.rx_sema = threading.Semaphore(0) def connect(self):