diff --git a/etc/valet/openstack/notification_listener/notification_listener.py b/etc/valet/openstack/notification_listener/notification_listener.py
index 764fd89..357da55 100644
--- a/etc/valet/openstack/notification_listener/notification_listener.py
+++ b/etc/valet/openstack/notification_listener/notification_listener.py
@@ -36,7 +36,7 @@ class NotificationEndpoint(object):
         """Error."""
         None
 
-transport = oslo_messaging.get_transport(cfg.CONF)
+transport = oslo_messaging.get_notification_transport(cfg.CONF)
 targets = [oslo_messaging.Target(topic='notifications')]
 endpoints = [NotificationEndpoint()]
 
diff --git a/valet/api/common/messaging.py b/valet/api/common/messaging.py
index af2f743..999980b 100644
--- a/valet/api/common/messaging.py
+++ b/valet/api/common/messaging.py
@@ -23,7 +23,7 @@ from pecan import conf
 def _messaging_notifier_from_config(config):
     """Initialize the messaging engine based on supplied config."""
     transport_url = config.get('transport_url')
-    transport = messaging.get_transport(cfg.CONF, transport_url)
+    transport = messaging.get_notification_transport(cfg.CONF, transport_url)
     notifier = messaging.Notifier(transport, driver='messaging',
                                   publisher_id='valet',
                                   topic='notifications', retry=10)