diff --git a/vitrage/api_handler/apis/event.py b/vitrage/api_handler/apis/event.py
index 18f709ccb..97b906da8 100644
--- a/vitrage/api_handler/apis/event.py
+++ b/vitrage/api_handler/apis/event.py
@@ -57,6 +57,6 @@ class EventApis(EntityGraphApisBase):
                 get_transport(self.conf),
                 driver='messagingv2',
                 publisher_id=self.publisher,
-                topic='vitrage_notifications')
+                topics=['vitrage_notifications'])
         except Exception as e:
             LOG.info('Failed to initialize oslo notifier %s', str(e))
diff --git a/vitrage/datasources/collectd/collectd_vitrage/vitrageplugin.py b/vitrage/datasources/collectd/collectd_vitrage/vitrageplugin.py
index 44ff3cc54..b317f88f0 100644
--- a/vitrage/datasources/collectd/collectd_vitrage/vitrageplugin.py
+++ b/vitrage/datasources/collectd/collectd_vitrage/vitrageplugin.py
@@ -54,7 +54,7 @@ class VitrageNotifier(CollectDPlugin):
         self.notifier = messaging.Notifier(transport,
                                            driver='messagingv2',
                                            publisher_id='collectd',
-                                           topic='vitrage_notifications')
+                                           topics=['vitrage_notifications'])
         self.add_notification_callback(self.notify)
 
     def notify(self, notification):
diff --git a/vitrage/datasources/zabbix/auxiliary/zabbix_vitrage.py b/vitrage/datasources/zabbix/auxiliary/zabbix_vitrage.py
index 8ea599263..8b1a99b4c 100644
--- a/vitrage/datasources/zabbix/auxiliary/zabbix_vitrage.py
+++ b/vitrage/datasources/zabbix/auxiliary/zabbix_vitrage.py
@@ -74,7 +74,7 @@ def main():
     notifier = messaging.Notifier(transport,
                                   driver=driver,
                                   publisher_id=publisher,
-                                  topic='vitrage_notifications')
+                                  topics=['vitrage_notifications'])
 
     alarm_status = args.topic.lower()
     event_type = '%s.%s' % (ZABBIX_EVENT_TYPE, alarm_status)
diff --git a/vitrage/entity_graph/processor/notifier.py b/vitrage/entity_graph/processor/notifier.py
index 8cf33ded9..10797c0ce 100644
--- a/vitrage/entity_graph/processor/notifier.py
+++ b/vitrage/entity_graph/processor/notifier.py
@@ -39,7 +39,7 @@ class GraphNotifier(object):
                 get_transport(conf),
                 driver='messagingv2',
                 publisher_id='vitrage.graph',
-                topic=topic)
+                topics=[topic])
         except Exception as e:
             LOG.info('Graph Notifier - missing configuration %s' % str(e))
 
diff --git a/vitrage/messaging.py b/vitrage/messaging.py
index 455b10a67..28ccd8e8b 100644
--- a/vitrage/messaging.py
+++ b/vitrage/messaging.py
@@ -64,7 +64,7 @@ class VitrageNotifier(object):
             transport,
             driver='messagingv2',
             publisher_id=publisher_id,
-            topic=topic)
+            topics=[topic])
 
     def notify(self, event_type, data):
         LOG.debug('notify : ' + event_type + ' ' + str(data))