diff --git a/oslo_messaging/_drivers/impl_rabbit.py b/oslo_messaging/_drivers/impl_rabbit.py
index 053f0b39d..8c696cb7e 100644
--- a/oslo_messaging/_drivers/impl_rabbit.py
+++ b/oslo_messaging/_drivers/impl_rabbit.py
@@ -437,7 +437,8 @@ class Connection(object):
             self._url, ssl=self._fetch_ssl_params(),
             login_method=self._login_method,
             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'),
                  self.connection.info())
diff --git a/oslo_messaging/tests/drivers/test_impl_rabbit.py b/oslo_messaging/tests/drivers/test_impl_rabbit.py
index 7008f23f5..1e942a9cf 100644
--- a/oslo_messaging/tests/drivers/test_impl_rabbit.py
+++ b/oslo_messaging/tests/drivers/test_impl_rabbit.py
@@ -169,7 +169,8 @@ class TestRabbitDriverLoadSSL(test_utils.BaseTestCase):
 
         transport._driver._get_connection()
         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")