summaryrefslogtreecommitdiff
path: root/oslo_messaging/opts.py
diff options
context:
space:
mode:
authorJames Page <james.page@ubuntu.com>2015-04-23 17:08:24 +0100
committerJames Page <james.page@ubuntu.com>2015-04-26 11:01:04 +0100
commitde015d5c8308bf5b9cc723c398ae4b91ec814347 (patch)
tree1a9cc67f8129605174a1ac55808823f53d3b9067 /oslo_messaging/opts.py
parent287a4f56f45ed9cd40116a9e7b6e529f3382a925 (diff)
downloadoslo-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.py2
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,