bug fix

Macrometacorp · Mar 26, 2020 · 909135e · 909135e
1 parent 8ce84ce
commit 909135e
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/c8/fabric.py b/c8/fabric.py
@@ -138,12 +138,12 @@ def on_change(self, collection, callback=printdata):
         subscription_name = "%s-%s-subscription-%s" % (
             self.tenant_name, self.fabric_name, str(random.randint(1, 1000)))
 
+        url = self.url.split("//")[1].split(":")[0]
+
         topic = "wss://{}/_ws/ws/v2/consumer/persistent/{}/{}/{}/{}".format(
-            self.url+":"+str(self.stream_port),self.tenant_name,namespace,
+            url,self.tenant_name,namespace,
             collection,subscription_name)
 
-        print(topic)
-
         ws = websocket.create_connection(topic)
 
         try: