openstack/oslo.messaging
Code Issues Proposed changes

Add initial qpid driver

Browse Source 
This just adds a QpidDriver which re-uses AMQPDriver.

The test-rabbit-{client,server}.py test scripts works fine with this
driver and the URL changed to qpid:///

Change-Id: Ifb72853e83b678b311fecb21fe016af19a67b272
This commit is contained in:
Mark McLoughlin 2013-07-29 07:38:29 +01:00
parent 85a386765f
commit da539a094d
1 changed files with 15 additions and 2 deletions

17
oslo/messaging/_drivers/impl_qpid.py

@ -25,8 +25,9 @@ import eventlet
import greenlet
from oslo.config import cfg
from oslo.messaging._drivers.rpc import amqp as rpc_amqp
from oslo.messaging._drivers.rpc import common as rpc_common
from oslo.messaging._drivers import amqp as rpc_amqp
from oslo.messaging._drivers import amqpdriver
from oslo.messaging._drivers import common as rpc_common
from oslo.messaging.openstack.common import excutils
from oslo.messaging.openstack.common import importutils
from oslo.messaging.openstack.common import jsonutils
@ -737,3 +738,15 @@ def notify(conf, context, topic, msg, envelope):
def cleanup():
return rpc_amqp.cleanup(Connection.pool)
class QpidDriver(amqpdriver.AMQPDriverBase):
def __init__(self, conf, url=None, default_exchange=None):
conf.register_opts(qpid_opts)
conf.register_opts(rpc_amqp.amqp_opts)
connection_pool = rpc_amqp.get_connection_pool(conf, Connection)
super(QpidDriver, self).__init__(conf, connection_pool,
url, default_exchange)