#
#

import asyncio
import logging
import signal


def main():
  loop = asyncio.get_event_loop()

  signals = (signal.SIGHUP, signal.SIGTERM, signal.SIGINT)
  for s in signals:
    loop.add_signal_handler(s, lambda s=s: asyncio.create_task(shutdown(s, loop)))

  # use loop, add consumers/producers etc.

  try:
    #
    loop.run_forever()
  finally:
    log.info("Cleaning up")
    loop.stop()
    # loop.close()