Bump v0.6.5

vishr · vishr · commit db5a86032e27 · 2017-09-01T13:30:20.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 .connect import _Connect 
+from .queue import _Queue
 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 connect(self, client_id):
-    return _Connect(self.account_id, self.api_key, client_id)
+  def queue(self, client_id):
+    return _Queue(self.account_id, self.api_key, client_id)
 
   def email(self):
     return _Email(self.interceptor)
diff --git a/labstack/queue.py b/labstack/queue.py
@@ -1,6 +1,6 @@
 import paho.mqtt.client as mqtt
 
-class _Connect():
+class _Queue():
   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)
@@ -20,8 +20,11 @@ def on_message(client, userdata, msg):
   def publish(self, topic, message):
     self.client.publish('{}/{}'.format(self.account_id, topic), message)
 
-  def subscribe(self, topic):
-    self.client.subscribe('{}/{}'.format(self.account_id, topic))
+  def subscribe(self, topic, shared=False):
+    topic = '{}/{}'.format(self.account_id, topic)
+    if shared:
+      topic = '$queue/' + topic
+    self.client.subscribe(topic)
 
   def disconnect(self):
     self.client.disconnect()
diff --git a/setup.py b/setup.py
@@ -2,7 +2,7 @@
 
 setup(
   name='labstack',
-  version='0.6.4',
+  version='0.6.5',
   description='Official Python client library for the LabStack platform',
   long_description='`<https://github.com/labstack/labstack-python>`_',
   keywords='labstack cube email log mqtt store',
