x/deb-oslo.messaging
Code Issues Proposed changes

Correctly set socket timeout for publishing

Browse Source 
Previously a wrong attribute was taken which does not work with
current versions of kombu and amqp we have in gate.

Change-Id: I9dc2453be3047f993930c2b5c1e74720c8c3b26c
This commit is contained in:
Dmitry Mescheryakov
2016-02-02 00:26:32 +03:00
parent db7fd2d27b
commit 0fb20d8d49
2 changed files with 13 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -90,11 +90,11 @@ class TestHeartbeat(test_utils.BaseTestCase):
if not heartbeat_side_effect:
self.assertEqual(1, fake_ensure_connection.call_count)
self.assertEqual(2, fake_logger.debug.call_count)
self.assertEqual(3, fake_logger.debug.call_count)
self.assertEqual(0, fake_logger.info.call_count)
else:
self.assertEqual(2, fake_ensure_connection.call_count)
self.assertEqual(2, fake_logger.debug.call_count)
self.assertEqual(3, fake_logger.debug.call_count)
self.assertEqual(1, fake_logger.info.call_count)
self.assertIn(mock.call(info, mock.ANY),
fake_logger.info.mock_calls)