summaryrefslogtreecommitdiffstats
path: root/openstack/common/rpc
diff options
context:
space:
mode:
authorMonty Taylor <mordred@inaugust.com>2013-04-03 11:20:33 -0400
committerMonty Taylor <mordred@inaugust.com>2013-04-07 02:32:37 -0400
commit0b15de18fba81acfcffc5861f34e0199caef8fb9 (patch)
tree1f7a1240b95645d2abd0a4c47adcafebe925b2d1 /openstack/common/rpc
parent49153d44ca6620a5027b56036e4077725aa90faf (diff)
downloadoslo-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-xopenstack/common/rpc/zmq_receiver.py41
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()