X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=osm_mon%2Fplugins%2FOpenStack%2FAodh%2Falarming.py;h=cea12baa9df700731217555914e71b5ef63e86f1;hb=cbecb0d35d5da2b127c85c2c90515c4ad72a8467;hp=44b8fddb5fa14a4eba7b379b5b475f541e3f1eb3;hpb=e2fe4582e9569ea8146e945f278179126821ab76;p=osm%2FMON.git

diff --git a/osm_mon/plugins/OpenStack/Aodh/alarming.py b/osm_mon/plugins/OpenStack/Aodh/alarming.py
index 44b8fdd..cea12ba 100644
--- a/osm_mon/plugins/OpenStack/Aodh/alarming.py
+++ b/osm_mon/plugins/OpenStack/Aodh/alarming.py
@@ -108,7 +108,7 @@ class Alarming(object):
                                                   alarm_details['operation'].lower(),
                                                   alarm_details['metric_name'].lower(),
                                                   alarm_details['vdu_name'].lower(),
-                                                  alarm_details['vnf_member_index'].lower(),
+                                                  alarm_details['vnf_member_index'],
                                                   alarm_details['ns_id'].lower()
                                                   )
                 status = True
@@ -177,7 +177,7 @@ class Alarming(object):
                 log.exception("Error updating alarm")
                 raise e
             finally:
-                self._generate_and_send_response('create_alarm_response',
+                self._generate_and_send_response('update_alarm_response',
                                                  alarm_details['correlation_id'],
                                                  status=status,
                                                  alarm_id=alarm_id)
@@ -387,13 +387,13 @@ class Alarming(object):
             log.exception("Desired Gnocchi metric not found:", e)
             raise e
 
-    def _generate_and_send_response(self, topic, correlation_id, **kwargs):
+    def _generate_and_send_response(self, key, correlation_id, **kwargs):
         try:
             resp_message = self._response.generate_response(
-                topic, cor_id=correlation_id, **kwargs)
+                key, cor_id=correlation_id, **kwargs)
             log.info("Response Message: %s", resp_message)
-            self._producer.create_alarm_response(
-                topic, resp_message)
+            self._producer.publish_alarm_response(
+                key, resp_message)
         except Exception as e:
             log.exception("Response creation failed:")
             raise e