kopia lustrzana https://github.com/Yakifo/amqtt
Rename plugin namespace
rodzic
90fb11ad8c
commit
a17ae34361
|
@ -177,7 +177,7 @@ class Broker:
|
||||||
self.sys_handle = None
|
self.sys_handle = None
|
||||||
|
|
||||||
# Init plugins manager
|
# Init plugins manager
|
||||||
self.plugins_manager = PluginManager('hbmqtt.broker', BrokerContext(self._loop), self._loop)
|
self.plugins_manager = PluginManager('hbmqtt.broker.plugins', BrokerContext(self._loop), self._loop)
|
||||||
|
|
||||||
def _build_listeners_config(self, broker_config):
|
def _build_listeners_config(self, broker_config):
|
||||||
self.listeners_config = dict()
|
self.listeners_config = dict()
|
||||||
|
|
|
@ -89,7 +89,7 @@ class MQTTClient:
|
||||||
self._connection_closed_future = None
|
self._connection_closed_future = None
|
||||||
|
|
||||||
# Init plugins manager
|
# Init plugins manager
|
||||||
self.plugins_manager = PluginManager('hbmqtt.client', ClientContext(self))
|
self.plugins_manager = PluginManager('hbmqtt.client.plugins', ClientContext(self))
|
||||||
|
|
||||||
|
|
||||||
@asyncio.coroutine
|
@asyncio.coroutine
|
||||||
|
|
4
setup.py
4
setup.py
|
@ -36,11 +36,11 @@ setup(
|
||||||
'test_plugin = tests.plugins.test_manager:TestPlugin',
|
'test_plugin = tests.plugins.test_manager:TestPlugin',
|
||||||
'event_plugin = tests.plugins.test_manager:EventTestPlugin',
|
'event_plugin = tests.plugins.test_manager:EventTestPlugin',
|
||||||
],
|
],
|
||||||
'hbmqtt.broker': [
|
'hbmqtt.broker.plugins': [
|
||||||
# 'event_logger_plugin = hbmqtt.plugins:EventLoggerPlugin',
|
# 'event_logger_plugin = hbmqtt.plugins:EventLoggerPlugin',
|
||||||
'packet_logger_plugin = hbmqtt.plugins:PacketLoggerPlugin',
|
'packet_logger_plugin = hbmqtt.plugins:PacketLoggerPlugin',
|
||||||
],
|
],
|
||||||
'hbmqtt.client': [
|
'hbmqtt.client.plugins': [
|
||||||
'packet_logger_plugin = hbmqtt.plugins:PacketLoggerPlugin',
|
'packet_logger_plugin = hbmqtt.plugins:PacketLoggerPlugin',
|
||||||
]
|
]
|
||||||
}
|
}
|
||||||
|
|
Ładowanie…
Reference in New Issue