¡@

Home 

OpenStack Study: zmq_receiver.py

OpenStack Index

**** CubicPower OpenStack Study ****

def main():

    CONF(sys.argv[1:], project='oslo')

    logging.setup("oslo")

    with contextlib.closing(impl_zmq.ZmqProxy(CONF)) as reactor:

        reactor.consume_in_thread()

        reactor.wait()