diff options
author | Michael J Fork <mjfork@us.ibm.com> | 2013-03-11 13:26:59 +0000 |
---|---|---|
committer | Michael J Fork <mjfork@us.ibm.com> | 2013-03-11 22:20:35 +0000 |
commit | 1e6e6d5968da8b9dce294060b3934699d2ddc04b (patch) | |
tree | c45581dd25d2da7600db6ba5813b35e16533f9b1 /bin | |
parent | 6b9ce709fc05e5c734094cea5196bcdbea43e0dc (diff) | |
download | neutron-1e6e6d5968da8b9dce294060b3934699d2ddc04b.tar.gz |
Update oslo rpc libraries
Update oslo rpc libraries to capture changes, primarly motivated
by secret=True flag on password config options.
Added bin/quantum-rpc-zmq-receiver
Change-Id: I40d3ef1a85901e5b9eab803cc67cdad3cbb0719a
Diffstat (limited to 'bin')
-rwxr-xr-x | bin/quantum-rpc-zmq-receiver | 53 |
1 files changed, 53 insertions, 0 deletions
diff --git a/bin/quantum-rpc-zmq-receiver b/bin/quantum-rpc-zmq-receiver new file mode 100755 index 0000000000..d79fdb515f --- /dev/null +++ b/bin/quantum-rpc-zmq-receiver @@ -0,0 +1,53 @@ +#!/usr/bin/env python +# vim: tabstop=4 shiftwidth=4 softtabstop=4 + +# Copyright 2011 OpenStack LLC +# +# 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 os +import sys + +# If ../quantum/__init__.py exists, add ../ to Python search path, so that +# it will override what happens to be installed in /usr/(local/)lib/python... +POSSIBLE_TOPDIR = os.path.normpath(os.path.join(os.path.abspath(sys.argv[0]), + os.pardir, + os.pardir)) +if os.path.exists(os.path.join(POSSIBLE_TOPDIR, 'quantum', '__init__.py')): + sys.path.insert(0, POSSIBLE_TOPDIR) + +from oslo.config import cfg + +from quantum.openstack.common import log as logging +from quantum.openstack.common import rpc +from quantum.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='quantum') + logging.setup("quantum") + + with contextlib.closing(impl_zmq.ZmqProxy(CONF)) as reactor: + reactor.consume_in_thread() + reactor.wait() + +if __name__ == '__main__': + main() |