Bumped v0.6.6

vishr · vishr · commit 5b676e205131 · 2017-09-10T18:56:57.000-07:00
Signed-off-by: Vishal Rana &lt;vr@labstack.com&gt;
diff --git a/labstack/client.py b/labstack/client.py
@@ -1,5 +1,5 @@
 import requests
-from .queue import _Queue
+from .message import _Message
 from .email import _Email
 from .log import _Log
 from .store import _Store
@@ -19,8 +19,8 @@ def __init__(self, account_id, api_key):
     self.api_key = api_key
     self.interceptor = _Interceptor(api_key)
 
-  def queue(self, client_id):
-    return _Queue(self.account_id, self.api_key, client_id)
+  def message(self, client_id):
+    return _Message(self.account_id, self.api_key, client_id)
 
   def email(self):
     return _Email(self.interceptor)
diff --git a/labstack/message.py b/labstack/message.py
@@ -1,6 +1,6 @@
 import paho.mqtt.client as mqtt
 
-class _Queue():
+class _Message():
   def __init__(self, account_id, api_key, client_id):
     self.account_id = account_id
     self.client = mqtt.Client(client_id=client_id, clean_session=True)
@@ -12,10 +12,10 @@ def on_connect(client, userdata, flags, rc):
       handler()
     self.client.on_connect = on_connect
 
-  def on_message(self, handler):
-    def on_message(client, userdata, msg):
+  def on_data(self, handler):
+    def on_data(client, userdata, msg):
       handler(msg.topic, msg.payload)
-    self.client.on_message = on_message
+    self.client.on_message = on_data
 
   def publish(self, topic, message):
     self.client.publish('{}/{}'.format(self.account_id, topic), message)
diff --git a/setup.py b/setup.py
@@ -2,7 +2,7 @@
 
 setup(
   name='labstack',
-  version='0.6.5',
+  version='0.6.6',
   description='Official Python client library for the LabStack platform',
   long_description='`<https://github.com/labstack/labstack-python>`_',
   keywords='labstack cube email log mqtt store',
