diff options
| author | Monty Taylor <mordred@inaugust.com> | 2013-04-03 11:20:33 -0400 |
|---|---|---|
| committer | Monty Taylor <mordred@inaugust.com> | 2013-04-07 02:32:37 -0400 |
| commit | 0b15de18fba81acfcffc5861f34e0199caef8fb9 (patch) | |
| tree | 1f7a1240b95645d2abd0a4c47adcafebe925b2d1 /openstack/common/rpc | |
| parent | 49153d44ca6620a5027b56036e4077725aa90faf (diff) | |
| download | oslo-0b15de18fba81acfcffc5861f34e0199caef8fb9.tar.gz oslo-0b15de18fba81acfcffc5861f34e0199caef8fb9.tar.xz oslo-0b15de18fba81acfcffc5861f34e0199caef8fb9.zip | |
Move bin/ scripts to entrypoints.
Instead of propogating more bin scripts, migrate these to be things
that can be consumed as entrypoints.
Change-Id: Ic01e0f16fe9e7634708fbb51499ccea3f4f40d63
Diffstat (limited to 'openstack/common/rpc')
| -rwxr-xr-x | openstack/common/rpc/zmq_receiver.py | 41 |
1 files changed, 41 insertions, 0 deletions
diff --git a/openstack/common/rpc/zmq_receiver.py b/openstack/common/rpc/zmq_receiver.py new file mode 100755 index 0000000..e74da22 --- /dev/null +++ b/openstack/common/rpc/zmq_receiver.py @@ -0,0 +1,41 @@ +#!/usr/bin/env python +# vim: tabstop=4 shiftwidth=4 softtabstop=4 + +# Copyright 2011 OpenStack Foundation +# +# Licensed under the Apache License, Version 2.0 (the "License"); you may +# not use this file except in compliance with the License. You may obtain +# a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT +# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the +# License for the specific language governing permissions and limitations +# under the License. + +import eventlet +eventlet.monkey_patch() + +import contextlib +import sys + +from oslo.config import cfg + +from openstack.common import log as logging +from openstack.common import rpc +from openstack.common.rpc import impl_zmq + +CONF = cfg.CONF +CONF.register_opts(rpc.rpc_opts) +CONF.register_opts(impl_zmq.zmq_opts) + + +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() |
