Correct local MQTT broker max connections param (#146)

* Correct local MQTT broker max connections param

Snake case aMQTT broker max conections parameter
to match v0.11.3.

Ref - https://amqtt.readthedocs.io/en/v0.11.3/references/broker_config/

* Further fixes

* Update to be Python 3.10+ compatible

Asyncio usage pattern has changed

Author: kstribrnAmzn

localhost-mqtt-broker/localhost_mqtt_broker.py

@@ -36,41 +36,45 @@
         "default": {
             "type": "tcp",
             "bind": f"{args.host}:1883",
-            "max-connections": 1000,
+            "max_connections": 1000,
         },
         "tls": {
             "type": "tcp",
             "bind": f"{args.host}:8883",
-            "max-connections": 1000,
-            "ssl": "on",
+            "max_connections": 1000,
+            "ssl": True,
             "cafile": args.root_ca_cert_path,
             "certfile": args.server_cert_path,
             "keyfile": args.server_priv_key_path,
         },
     },
-    "sys_interval": 10,
-    "auth": {
-        "allow-anonymous": True,
-        "password-file": os.path.join(
-            os.path.dirname(os.path.realpath(__file__)), "passwd"
-        ),
-        "plugins": ["auth_anonymous"],
-    },
-    "topic-check": {
-        "enabled": True,
-        "plugins": []
+    "timeout_disconnect_delay": 0,
+    "plugins": {
+        "amqtt.plugins.logging_amqtt.EventLoggerPlugin": {},
+        "amqtt.plugins.logging_amqtt.PacketLoggerPlugin": {},
+        "amqtt.plugins.authentication.AnonymousAuthPlugin": {
+            "allow_anonymous": True
+        },
+        "amqtt.plugins.authentication.FileAuthPlugin": {
+            "password_file": os.path.join(
+                os.path.dirname(os.path.realpath(__file__)), "passwd"
+            )
+        },
+        "amqtt.plugins.sys.broker.BrokerSysPlugin": {
+            "sys_interval": 10
+        },
     },
 }
 
-broker = Broker(config)
-
 async def broker_coroutine():
+    broker = Broker(config)
     await broker.start()
+    # Keep the broker running indefinitely
+    await asyncio.Event().wait()
 
 if __name__ == "__main__":
     formatter = "[%(asctime)s] :: %(levelname)s :: %(name)s :: %(message)s"
     logging.basicConfig(level=logging.DEBUG, format=formatter)
 
     # Start the MQTT broker
-    asyncio.get_event_loop().run_until_complete(broker_coroutine())
-    asyncio.get_event_loop().run_forever()
+    asyncio.run(broker_coroutine())