openstack/oslo.messaging
Code Issues Proposed changes

Merge "Adding Publisher Acknowledgements/confirms"

Browse Source
This commit is contained in:
Jenkins 2015-05-28 11:13:11 +00:00 committed by Gerrit Code Review
commit baddce34a2
2 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
oslo_messaging/_drivers/impl_rabbit.py
View File

@ -437,7 +437,8 @@ class Connection(object):
self._url, ssl=self._fetch_ssl_params(), self._url, ssl=self._fetch_ssl_params(),
login_method=self._login_method, login_method=self._login_method,
failover_strategy="shuffle", failover_strategy="shuffle",
heartbeat=self.driver_conf.heartbeat_timeout_threshold) heartbeat=self.driver_conf.heartbeat_timeout_threshold,
transport_options={'confirm_publish': True})
LOG.info(_LI('Connecting to AMQP server on %(hostname)s:%(port)s'), LOG.info(_LI('Connecting to AMQP server on %(hostname)s:%(port)s'),
self.connection.info()) self.connection.info())

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

@ -169,7 +169,8 @@ class TestRabbitDriverLoadSSL(test_utils.BaseTestCase):
transport._driver._get_connection() transport._driver._get_connection()
connection_klass.assert_called_once_with( connection_klass.assert_called_once_with(
'memory:///', ssl=self.expected, login_method='AMQPLAIN', 'memory:///', transport_options={'confirm_publish': True},
ssl=self.expected, login_method='AMQPLAIN',
heartbeat=0, failover_strategy="shuffle") heartbeat=0, failover_strategy="shuffle")