openstack/oslo.messaging
Code Issues Proposed changes

Use oslo.log in the zmq receiver

Browse Source 
The zmq receiver must allow to be configurable like any other
openstack daemon.

Change-Id: I8db72239d6be04c25bef37a539b7c4ecd457225b
This commit is contained in:
Mehdi Abaakouk 2015-07-08 13:40:29 +02:00 committed by Victor Sergeyev
parent 3b891fcfcb
commit 79b308bc8c
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
oslo_messaging/_cmd/zmq_receiver.py
View File

@ -18,10 +18,10 @@ import eventlet
eventlet.monkey_patch() eventlet.monkey_patch()
import contextlib import contextlib
import logging
import sys import sys
from oslo_config import cfg from oslo_config import cfg
from oslo_log import log
from oslo_messaging._drivers import impl_zmq from oslo_messaging._drivers import impl_zmq
from oslo_messaging._executors import base # FIXME(markmc) from oslo_messaging._executors import base # FIXME(markmc)
@ -33,7 +33,7 @@ CONF.register_opts(base._pool_opts)
def main(): def main():
CONF(sys.argv[1:], project='oslo') CONF(sys.argv[1:], project='oslo')
logging.basicConfig(level=logging.DEBUG) log.setup(CONF, 'oslo.messaging')
with contextlib.closing(impl_zmq.ZmqProxy(CONF)) as reactor: with contextlib.closing(impl_zmq.ZmqProxy(CONF)) as reactor:
reactor.consume_in_thread() reactor.consume_in_thread()

1
requirements.txt
View File

@ -6,6 +6,7 @@ pbr<2.0,>=0.11
oslo.config>=1.11.0 # Apache-2.0 oslo.config>=1.11.0 # Apache-2.0
oslo.context>=0.2.0 # Apache-2.0 oslo.context>=0.2.0 # Apache-2.0
oslo.log>=1.2.0 # Apache-2.0
oslo.utils>=1.6.0 # Apache-2.0 oslo.utils>=1.6.0 # Apache-2.0
oslo.serialization>=1.4.0 # Apache-2.0 oslo.serialization>=1.4.0 # Apache-2.0
oslo.service>=0.1.0 # Apache-2.0 oslo.service>=0.1.0 # Apache-2.0