openstack/oslo.messaging
Code Issues Proposed changes

Merge "Work with kombu from upstream"

Browse Source
This commit is contained in:
Jenkins 2016-03-02 15:04:14 +00:00 committed by Gerrit Code Review
commit 9db1cc728c
1 changed files with 15 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
oslo_messaging/tests/drivers/test_impl_rabbit.py
View File

@ -269,21 +269,22 @@ class TestRabbitPublisher(test_utils.BaseTestCase):
conn._publish_and_creates_default_queue,
exchange, {}, routing_key='foobar')
# Ensure the exchange does not exists
self.assertRaises(exc, try_send, e_passive)
# Create it
try_send(e_active)
# Ensure it creates it
try_send(e_passive)
with mock.patch('kombu.messaging.Producer', side_effect=exc):
# Should reset the cache and ensures the exchange does
# not exists
with mock.patch('kombu.transport.virtual.Channel.close'):
# Ensure the exchange does not exists
self.assertRaises(exc, try_send, e_passive)
# Recreate it
try_send(e_active)
# Ensure it have been recreated
try_send(e_passive)
# Create it
try_send(e_active)
# Ensure it creates it
try_send(e_passive)
with mock.patch('kombu.messaging.Producer', side_effect=exc):
# Should reset the cache and ensures the exchange does
# not exists
self.assertRaises(exc, try_send, e_passive)
# Recreate it
try_send(e_active)
# Ensure it have been recreated
try_send(e_passive)
class TestRabbitConsume(test_utils.BaseTestCase):