amqtt/samples/broker_start.py

import logging
import asyncio
from hbmqtt.broker import Broker

logger = logging.getLogger(__name__)

config = {
    'listeners': {
        'default': {
            'type': 'tcp'
        },
        'tcp-mqtt': {
            'bind': '0.0.0.0:1883',
            'max_connections': 10
        },
        'ws-mqtt': {
            'bind': '127.0.0.1:8080',
            'type': 'ws'
        },
    },
    'sys_interval': 0,
}

broker = Broker(config)

@asyncio.coroutine
def test_coro():
    yield from broker.start()
    #yield from asyncio.sleep(5)
    #yield from broker.shutdown()


if __name__ == '__main__':
    formatter = "[%(asctime)s] %(name)s {%(filename)s:%(lineno)d} %(levelname)s - %(message)s"
    logging.basicConfig(level=logging.DEBUG, format=formatter)
    asyncio.get_event_loop().run_until_complete(test_coro())
    asyncio.get_event_loop().run_forever()