diff options
Diffstat (limited to 'oslo_messaging/tests/functional/test_rabbitmq.py')
| -rw-r--r-- | oslo_messaging/tests/functional/test_rabbitmq.py | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/oslo_messaging/tests/functional/test_rabbitmq.py b/oslo_messaging/tests/functional/test_rabbitmq.py index db06d01..84f84e8 100644 --- a/oslo_messaging/tests/functional/test_rabbitmq.py +++ b/oslo_messaging/tests/functional/test_rabbitmq.py @@ -39,6 +39,12 @@ class RabbitMQFailoverTests(test_utils.BaseTestCase): ] def test_failover_scenario(self): + self._test_failover_scenario() + + def test_failover_scenario_enable_cancel_on_failover(self): + self._test_failover_scenario(enable_cancel_on_failover=True) + + def _test_failover_scenario(self, enable_cancel_on_failover=False): # NOTE(sileht): run this test only if functional suite run of a driver # that use rabbitmq as backend self.driver = os.environ.get('TRANSPORT_DRIVER') @@ -53,6 +59,7 @@ class RabbitMQFailoverTests(test_utils.BaseTestCase): kombu_reconnect_delay=0, rabbit_retry_interval=0, rabbit_retry_backoff=0, + enable_cancel_on_failover=enable_cancel_on_failover, group='oslo_messaging_rabbit') self.pifpaf = self.useFixture(rabbitmq.RabbitMQDriver(cluster=True, |