openstack
/
oslo.messaging
Code Issues Proposed changes

Merge "rabbit: test for new reply behavior"

This commit is contained in:
Jenkins 2015-06-05 11:20:37 +00:00 committed by Gerrit Code Review
parent 2d133bee84 bc6e2a8c15
commit 63bbdfc7c9
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -364,17 +364,25 @@ class TestSendReceive(test_utils.BaseTestCase):
('timeout', dict(timeout=0.01)), # FIXME(markmc): timeout=0 is broken? ('timeout', dict(timeout=0.01)), # FIXME(markmc): timeout=0 is broken?
] ]
_reply_ending = [
('old_behavior', dict(send_single_reply=False)),
('new_behavior', dict(send_single_reply=True)),
]
@classmethod @classmethod
def generate_scenarios(cls): def generate_scenarios(cls):
cls.scenarios = testscenarios.multiply_scenarios(cls._n_senders, cls.scenarios = testscenarios.multiply_scenarios(cls._n_senders,
cls._context, cls._context,
cls._reply, cls._reply,
cls._failure, cls._failure,
cls._timeout) cls._timeout,
cls._reply_ending)
def test_send_receive(self): def test_send_receive(self):
self.config(heartbeat_timeout_threshold=0, self.config(heartbeat_timeout_threshold=0,
group="oslo_messaging_rabbit") group="oslo_messaging_rabbit")
self.config(send_single_reply=self.send_single_reply,
group="oslo_messaging_rabbit")
transport = oslo_messaging.get_transport(self.conf, transport = oslo_messaging.get_transport(self.conf,
'kombu+memory:////') 'kombu+memory:////')
self.addCleanup(transport.cleanup) self.addCleanup(transport.cleanup)