diff --git a/swutil/pwmqtt.py b/swutil/pwmqtt.py
index ffd8e6b..86becca 100755
--- a/swutil/pwmqtt.py
+++ b/swutil/pwmqtt.py
@@ -45,7 +45,6 @@ def __init__(self, broker, port, qpub, qsub, name="pwmqtt", user = None, passwor
         self.user = user
         self.password = password
         self.subscriptions = {}
-        
         self.connect()
         debug("MQTT init done")
         
@@ -53,7 +52,7 @@ def connected(self):
         return (self.rc == 0)
         
     def connect(self):
-        self.mqttc = mosquitto.Mosquitto(self.name)
+        self.mqttc = mosquitto.Client(self.name)
         self.mqttc.on_message = self.on_message
         self.mqttc.on_connect = self.on_connect
         self.mqttc.on_disconnect = self.on_disconnect