amqtt
Advanced tools
| { | ||
| "listeners": { | ||
| "default": { | ||
| "type": "tcp", | ||
| "bind": "0.0.0.0:1883", | ||
| }, | ||
| }, | ||
| "sys_interval": 10, | ||
| "auth": { | ||
| "allow-anonymous": True, | ||
| "plugins": ["auth_anonymous"], | ||
| }, | ||
| "topic-check": { | ||
| "enabled": True, | ||
| "plugins": ["topic_acl"], | ||
| "acl": { | ||
| # username: [list of allowed topics] | ||
| "anonymous": [ | ||
| "#" | ||
| ], | ||
| }, | ||
| }, | ||
| } | ||
| # See the file license.txt for copying permission. | ||
| __version__ = "0.10.0-alpha.4" | ||
| __version__ = "0.10.0" |
@@ -197,9 +197,9 @@ # Copyright (c) 2015 Nicolas JOUANIN | ||
| async def _call_coro(plugin, coro_name, *args, **kwargs): | ||
| try: | ||
| coro = getattr(plugin.object, coro_name, None)(*args, **kwargs) | ||
| return await coro | ||
| except TypeError: | ||
| if not hasattr(plugin.object, coro_name): | ||
| # Plugin doesn't implement coro_name | ||
| return None | ||
| coro = getattr(plugin.object, coro_name)(*args, **kwargs) | ||
| return await coro | ||
| async def map_plugin_coro(self, coro_name, *args, **kwargs): | ||
@@ -206,0 +206,0 @@ """ |
+1
-1
| Metadata-Version: 2.1 | ||
| Name: amqtt | ||
| Version: 0.10.0a4 | ||
| Version: 0.10.0 | ||
| Summary: MQTT client/broker using Python asyncio | ||
@@ -5,0 +5,0 @@ Home-page: https://github.com/Yakifo/amqtt |
+1
-1
| [tool.poetry] | ||
| name = "amqtt" | ||
| version = "0.10.0-alpha.4" | ||
| version = "0.10.0" | ||
| description = "MQTT client/broker using Python asyncio" | ||
@@ -5,0 +5,0 @@ authors = ["aMQTT Contributers"] |
+1
-1
@@ -63,3 +63,3 @@ # -*- coding: utf-8 -*- | ||
| 'name': 'amqtt', | ||
| 'version': '0.10.0a4', | ||
| 'version': '0.10.0', | ||
| 'description': 'MQTT client/broker using Python asyncio', | ||
@@ -66,0 +66,0 @@ 'long_description': None, |
Alert delta unavailable
Currently unable to show alert delta for PyPI packages.
227510
0.2%90
1.12%5533
-0.02%