openstack/oslo.messaging
Code Issues Proposed changes

Merge "rabbit: add some tests when rpc_backend is set"

Browse Source
This commit is contained in:
Jenkins 2014-12-12 12:43:31 +00:00 committed by Gerrit Code Review
commit 935b5bd5fa
1 changed files with 14 additions and 4 deletions

18
tests/drivers/test_impl_rabbit.py

@ -55,16 +55,26 @@ class TestDeprecatedRabbitDriverLoad(test_utils.BaseTestCase):
class TestRabbitDriverLoad(test_utils.BaseTestCase): class TestRabbitDriverLoad(test_utils.BaseTestCase):
def setUp(self): scenarios = [
super(TestRabbitDriverLoad, self).setUp() ('rabbit', dict(transport_driver='rabbit',
self.messaging_conf.transport_driver = 'rabbit' url='amqp://guest:guest@localhost:5672//')),
('kombu', dict(transport_driver='kombu',
url='amqp://guest:guest@localhost:5672//')),
('rabbit+memory', dict(transport_driver='kombu+memory',
url='memory:///'))
]
@mock.patch('oslo.messaging._drivers.impl_rabbit.Connection.ensure') @mock.patch('oslo.messaging._drivers.impl_rabbit.Connection.ensure')
@mock.patch('oslo.messaging._drivers.impl_rabbit.Connection.reset') @mock.patch('oslo.messaging._drivers.impl_rabbit.Connection.reset')
def test_driver_load(self, fake_ensure, fake_reset): def test_driver_load(self, fake_ensure, fake_reset):
self.messaging_conf.transport_driver = self.transport_driver
transport = messaging.get_transport(self.conf) transport = messaging.get_transport(self.conf)
self.addCleanup(transport.cleanup) self.addCleanup(transport.cleanup)
self.assertIsInstance(transport._driver, rabbit_driver.RabbitDriver) driver = transport._driver
url = driver._get_connection()._url
self.assertIsInstance(driver, rabbit_driver.RabbitDriver)
self.assertEqual(self.url, url)
class TestRabbitIterconsume(test_utils.BaseTestCase): class TestRabbitIterconsume(test_utils.BaseTestCase):