[fix] fixed passing of subscription queue name to the NATS server (#3)

Gr1N · Aug 27, 2019 · 62f13fe · 62f13fe
1 parent 1ec1af9
commit 62f13fe
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 3 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -2,6 +2,8 @@
 
 ## 0.5.0 (2018-XX-XX)
 
+- Fixed passing of subscription queue name to the NATS server, #3
+
 ## 0.4.0 (2018-09-24)
 
 - Use `BytesIO` as read buffer

diff --git a/docker-compose.yml b/docker-compose.yml
@@ -1,7 +1,7 @@
-version: '3.6'
+version: "3.6"
 
 services:
   nats:
-    image: nats:1.2.0
+    image: nats:2.0.4
     ports:
       - 4222:4222
diff --git a/pynats/client.py b/pynats/client.py
@@ -166,7 +166,7 @@ def subscribe(
         sub = NATSSubscription(
             sid=self._ssid,
             subject=subject,
-            queue="",
+            queue=queue,
             callback=callback,
             max_messages=max_messages,
         )