diff options
| author | Dmitriy Ukhlov <dukhlov@mirantis.com> | 2016-04-28 00:02:34 -0500 |
|---|---|---|
| committer | Dmitriy Ukhlov <dukhlov@mirantis.com> | 2016-05-12 11:51:26 +0300 |
| commit | 63de855fef3e214029db606a4393bde8fae04352 (patch) | |
| tree | 75b4e624e750261c9113e9bd570f327914234d3c /oslo_messaging/opts.py | |
| parent | 6037b2b544b777bcafc5c2b55a0be94ecb2abfc1 (diff) | |
| download | oslo-messaging-63de855fef3e214029db606a4393bde8fae04352.tar.gz | |
Implements configurable connection factory
new - create new connection each times
single - use single connection for whole transport
read_write - use two connections for whole transport
(one for listening and one for sending)
Change-Id: I464c83beb498453b6df2237e7b8022d47ca3fa14
Diffstat (limited to 'oslo_messaging/opts.py')
| -rw-r--r-- | oslo_messaging/opts.py | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/oslo_messaging/opts.py b/oslo_messaging/opts.py index eb0878d..0687743 100644 --- a/oslo_messaging/opts.py +++ b/oslo_messaging/opts.py @@ -25,6 +25,7 @@ from oslo_messaging._drivers import base as drivers_base from oslo_messaging._drivers import impl_pika from oslo_messaging._drivers import impl_rabbit from oslo_messaging._drivers import impl_zmq +from oslo_messaging._drivers.pika_driver import pika_connection_factory from oslo_messaging._drivers.protocols.amqp import opts as amqp_opts from oslo_messaging._drivers.zmq_driver.matchmaker import matchmaker_redis from oslo_messaging.notify import notifier @@ -48,8 +49,9 @@ _opts = [ ('oslo_messaging_notifications', notifier._notifier_opts), ('oslo_messaging_rabbit', list( itertools.chain(amqp.amqp_opts, impl_rabbit.rabbit_opts, - impl_pika.pika_opts, impl_pika.pika_pool_opts, - impl_pika.notification_opts, impl_pika.rpc_opts))), + pika_connection_factory.pika_opts, + impl_pika.pika_pool_opts, impl_pika.notification_opts, + impl_pika.rpc_opts))), ] |