#!python

import os
import logging
import asyncio

from rabbitmq2solr import run

if __name__ == '__main__':
    logger = logging.getLogger("rabbitmq2solr")
    logger.setLevel(os.environ.get('LOG_LEVEL', "DEBUG"))
    handler = logging.StreamHandler()
    handler.setFormatter(
        logging.Formatter(
            os.environ.get('LOG_FORMAT', "%(asctime)s [%(levelname)s] %(name)s: %(message)s")
        )
    )
    logger.addHandler(handler)

    loop = asyncio.get_event_loop()
    loop.run_until_complete(run(loop=loop, logger=logger))