def recv_message(**kwargs):
    connection = BrokerConnection('amqp://%(mq_user)s:%(mq_password)s@'
                                  '%(mq_host)s:%(mq_port)s//'
                                  % kwargs['mq_args'])
    with connection as conn:
        try:
            SomeConsumer(conn, **kwargs).run()
        except __HOLE__:
            LOG.warning('Quitting %s' % __name__)
dataset/ETHPy150Open openstack/entropy/entropy/examples/repair/vmbooter.py/recv_message