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):