rename hbmqtt to amqtt in samples/

samples/broker_acl.py

@@ -1,7 +1,7 @@
 import logging
 import asyncio
 import os
-from hbmqtt.broker import Broker
+from amqtt.broker import Broker
 
 logger = logging.getLogger(__name__)
 

samples/broker_start.py

@@ -1,7 +1,7 @@
 import logging
 import asyncio
 import os
-from hbmqtt.broker import Broker
+from amqtt.broker import Broker
 
 logger = logging.getLogger(__name__)
 

samples/broker_taboo.py

@@ -1,7 +1,7 @@
 import logging
 import asyncio
 import os
-from hbmqtt.broker import Broker
+from amqtt.broker import Broker
 
 logger = logging.getLogger(__name__)
 

samples/client_keepalive.py

@@ -1,7 +1,7 @@
 import logging
 import asyncio
 
-from hbmqtt.client import MQTTClient
+from amqtt.client import MQTTClient
 
 
 #

samples/client_publish.py

@@ -1,8 +1,8 @@
 import logging
 import asyncio
 
-from hbmqtt.client import MQTTClient, ConnectException
+from amqtt.client import MQTTClient, ConnectException
-from hbmqtt.mqtt.constants import QOS_1, QOS_2
+from amqtt.mqtt.constants import QOS_1, QOS_2
 
 
 #

samples/client_publish_acl.py

@@ -1,7 +1,7 @@
 import logging
 import asyncio
 
-from hbmqtt.client import MQTTClient, ConnectException
+from amqtt.client import MQTTClient, ConnectException
 
 
 #
@@ -18,11 +18,11 @@ async def test_coro():
         await C.connect("mqtt://0.0.0.0:1883")
         await C.publish("data/classified", b"TOP SECRET", qos=0x01)
         await C.publish("data/memes", b"REAL FUN", qos=0x01)
-        await C.publish("repositories/hbmqtt/master", b"NEW STABLE RELEASE", qos=0x01)
+        await C.publish("repositories/amqtt/master", b"NEW STABLE RELEASE", qos=0x01)
         await C.publish(
-            "repositories/hbmqtt/devel", b"THIS NEEDS TO BE CHECKED", qos=0x01
+            "repositories/amqtt/devel", b"THIS NEEDS TO BE CHECKED", qos=0x01
         )
-        await C.publish("calendar/hbmqtt/releases", b"NEW RELEASE", qos=0x01)
+        await C.publish("calendar/amqtt/releases", b"NEW RELEASE", qos=0x01)
         logger.info("messages published")
         await C.disconnect()
     except ConnectException as ce:

samples/client_publish_ssl.py

@@ -1,8 +1,8 @@
 import logging
 import asyncio
 
-from hbmqtt.client import MQTTClient
+from amqtt.client import MQTTClient
-from hbmqtt.mqtt.constants import QOS_1, QOS_2
+from amqtt.mqtt.constants import QOS_1, QOS_2
 
 
 #

samples/client_publish_ws.py

@@ -1,8 +1,8 @@
 import logging
 import asyncio
 
-from hbmqtt.client import MQTTClient
+from amqtt.client import MQTTClient
-from hbmqtt.mqtt.constants import QOS_1, QOS_2
+from amqtt.mqtt.constants import QOS_1, QOS_2
 
 
 #

samples/client_subscribe.py

@@ -1,8 +1,8 @@
 import logging
 import asyncio
 
-from hbmqtt.client import MQTTClient, ClientException
+from amqtt.client import MQTTClient, ClientException
-from hbmqtt.mqtt.constants import QOS_1, QOS_2
+from amqtt.mqtt.constants import QOS_1, QOS_2
 
 
 #

samples/client_subscribe_acl.py

@@ -1,8 +1,8 @@
 import logging
 import asyncio
 
-from hbmqtt.client import MQTTClient, ClientException
+from amqtt.client import MQTTClient, ClientException
-from hbmqtt.mqtt.constants import QOS_1
+from amqtt.mqtt.constants import QOS_1
 
 
 #
@@ -23,9 +23,9 @@ async def uptime_coro():
         [
             ("data/memes", QOS_1),  # Topic allowed
             ("data/classified", QOS_1),  # Topic forbidden
-            ("repositories/hbmqtt/master", QOS_1),  # Topic allowed
+            ("repositories/amqtt/master", QOS_1),  # Topic allowed
-            ("repositories/hbmqtt/devel", QOS_1),  # Topic forbidden
+            ("repositories/amqtt/devel", QOS_1),  # Topic forbidden
-            ("calendar/hbmqtt/releases", QOS_1),  # Topic allowed
+            ("calendar/amqtt/releases", QOS_1),  # Topic allowed
         ]
     )
     logger.info("Subscribed")