diff --git a/samples/broker_acl.py b/samples/broker_acl.py index f3d06d7..b82b979 100644 --- a/samples/broker_acl.py +++ b/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__) diff --git a/samples/broker_start.py b/samples/broker_start.py index 8e0ade8..5eda57c 100644 --- a/samples/broker_start.py +++ b/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__) diff --git a/samples/broker_taboo.py b/samples/broker_taboo.py index bea6611..bed3c71 100644 --- a/samples/broker_taboo.py +++ b/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__) diff --git a/samples/client_keepalive.py b/samples/client_keepalive.py index eb734f1..0d7b8ab 100644 --- a/samples/client_keepalive.py +++ b/samples/client_keepalive.py @@ -1,7 +1,7 @@ import logging import asyncio -from hbmqtt.client import MQTTClient +from amqtt.client import MQTTClient # diff --git a/samples/client_publish.py b/samples/client_publish.py index 36f354d..5616d64 100644 --- a/samples/client_publish.py +++ b/samples/client_publish.py @@ -1,8 +1,8 @@ import logging import asyncio -from hbmqtt.client import MQTTClient, ConnectException -from hbmqtt.mqtt.constants import QOS_1, QOS_2 +from amqtt.client import MQTTClient, ConnectException +from amqtt.mqtt.constants import QOS_1, QOS_2 # diff --git a/samples/client_publish_acl.py b/samples/client_publish_acl.py index 865fd82..54476d2 100644 --- a/samples/client_publish_acl.py +++ b/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: diff --git a/samples/client_publish_ssl.py b/samples/client_publish_ssl.py index 9f71483..d495e2c 100644 --- a/samples/client_publish_ssl.py +++ b/samples/client_publish_ssl.py @@ -1,8 +1,8 @@ import logging import asyncio -from hbmqtt.client import MQTTClient -from hbmqtt.mqtt.constants import QOS_1, QOS_2 +from amqtt.client import MQTTClient +from amqtt.mqtt.constants import QOS_1, QOS_2 # diff --git a/samples/client_publish_ws.py b/samples/client_publish_ws.py index f74c794..e4cba93 100644 --- a/samples/client_publish_ws.py +++ b/samples/client_publish_ws.py @@ -1,8 +1,8 @@ import logging import asyncio -from hbmqtt.client import MQTTClient -from hbmqtt.mqtt.constants import QOS_1, QOS_2 +from amqtt.client import MQTTClient +from amqtt.mqtt.constants import QOS_1, QOS_2 # diff --git a/samples/client_subscribe.py b/samples/client_subscribe.py index 55a3f2b..ba46340 100644 --- a/samples/client_subscribe.py +++ b/samples/client_subscribe.py @@ -1,8 +1,8 @@ import logging import asyncio -from hbmqtt.client import MQTTClient, ClientException -from hbmqtt.mqtt.constants import QOS_1, QOS_2 +from amqtt.client import MQTTClient, ClientException +from amqtt.mqtt.constants import QOS_1, QOS_2 # diff --git a/samples/client_subscribe_acl.py b/samples/client_subscribe_acl.py index a120dc8..7bc25e3 100644 --- a/samples/client_subscribe_acl.py +++ b/samples/client_subscribe_acl.py @@ -1,8 +1,8 @@ import logging import asyncio -from hbmqtt.client import MQTTClient, ClientException -from hbmqtt.mqtt.constants import QOS_1 +from amqtt.client import MQTTClient, ClientException +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/hbmqtt/devel", QOS_1), # Topic forbidden - ("calendar/hbmqtt/releases", QOS_1), # Topic allowed + ("repositories/amqtt/master", QOS_1), # Topic allowed + ("repositories/amqtt/devel", QOS_1), # Topic forbidden + ("calendar/amqtt/releases", QOS_1), # Topic allowed ] ) logger.info("Subscribed")