diff options
author | James Page <james.page@ubuntu.com> | 2015-04-23 17:08:24 +0100 |
---|---|---|
committer | James Page <james.page@ubuntu.com> | 2015-04-26 11:01:04 +0100 |
commit | de015d5c8308bf5b9cc723c398ae4b91ec814347 (patch) | |
tree | 1a9cc67f8129605174a1ac55808823f53d3b9067 /oslo_messaging/opts.py | |
parent | 287a4f56f45ed9cd40116a9e7b6e529f3382a925 (diff) | |
download | oslo-messaging-de015d5c8308bf5b9cc723c398ae4b91ec814347.tar.gz |
zmq: Add support for ZmqClient pooling
To avoid creating a new ZMQ connection for every message sent
to a remote broker, implement pooling and re-use of ZmqClient
objects and associated ZMQ context.
A pool is created for each remote endpoint (keyed by address);
the size of each pool is configured using rpc_conn_pool_size.
All outbound message client connections are pooled.
Closes-Bug: 1384113
Change-Id: Ia55d5c310a56e51df5e2f5d39e561a4da3fe4d83
Diffstat (limited to 'oslo_messaging/opts.py')
-rw-r--r-- | oslo_messaging/opts.py | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/oslo_messaging/opts.py b/oslo_messaging/opts.py index 664e586..5911b69 100644 --- a/oslo_messaging/opts.py +++ b/oslo_messaging/opts.py @@ -21,6 +21,7 @@ import copy import itertools from oslo_messaging._drivers import amqp +from oslo_messaging._drivers import base as drivers_base from oslo_messaging._drivers import impl_qpid from oslo_messaging._drivers import impl_rabbit from oslo_messaging._drivers import impl_zmq @@ -34,6 +35,7 @@ from oslo_messaging.rpc import client from oslo_messaging import transport _global_opt_lists = [ + drivers_base.base_opts, impl_zmq.zmq_opts, matchmaker.matchmaker_opts, base._pool_opts, |