X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=plugins%2FvRealiseOps%2Fplugin_receiver.py;h=90b7480b89dcc15e1f9698021b856d687aa3b9db;hb=43d56d6c342d2a83d9d12f9cc25785b443ecb394;hp=e2150628843f0d340abb5813d18f938e98046c01;hpb=07f4f49ac725a07ba696b794fa26718a15d07082;p=osm%2FMON.git

diff --git a/plugins/vRealiseOps/plugin_receiver.py b/plugins/vRealiseOps/plugin_receiver.py
index e215062..90b7480 100644
--- a/plugins/vRealiseOps/plugin_receiver.py
+++ b/plugins/vRealiseOps/plugin_receiver.py
@@ -86,8 +86,11 @@ class PluginReceiver():
         """
         try:
             for message in self.consumer.vrops_consumer:
+                vim_type = None
+                self.logger.info("Message received:\nTopic={}:{}:{}:\nKey={}\nValue={}"\
+                    .format(message.topic, message.partition, message.offset, message.key, message.value))
                 message_values = json.loads(message.value)
-                if message_values.has_key('vim_type'):
+                if message_values.has_key('vim_type') and message_values['vim_type'] is not None:
                     vim_type = message_values['vim_type'].lower()
                 if vim_type == 'vmware':
                     self.logger.info("Action required for: {}".format(message.topic))
@@ -170,6 +173,8 @@ class PluginReceiver():
                              "status": True if alarm_uuid else False
                             }
                        }
+        self.logger.info("Publishing response:\nTopic={}\nKey={}\nValue={}"\
+                .format(topic, msg_key, response_msg))
         #Core producer
         self.producer_alarms.publish(key=msg_key, value=json.dumps(response_msg), topic=topic)
 
@@ -193,6 +198,8 @@ class PluginReceiver():
                              "status": True if alarm_uuid else False
                             }
                        }
+        self.logger.info("Publishing response:\nTopic={}\nKey={}\nValue={}"\
+                .format(topic, msg_key, response_msg))
         #Core producer
         self.producer_alarms.publish(key=msg_key, value=json.dumps(response_msg), topic=topic)
 
@@ -216,6 +223,8 @@ class PluginReceiver():
                              "status": True if alarm_uuid else False
                             }
                        }
+        self.logger.info("Publishing response:\nTopic={}\nKey={}\nValue={}"\
+                .format(topic, msg_key, response_msg))
         #Core producer
         self.producer_alarms.publish(key=msg_key, value=json.dumps(response_msg), topic=topic)
 
@@ -225,6 +234,8 @@ class PluginReceiver():
         """
         topic = 'metric_response'
         msg_key = 'read_metric_data_response'
+        self.logger.info("Publishing response:\nTopic={}\nKey={}\nValue={}"\
+                .format(topic, msg_key, metrics_data))
         #Core producer
         self.producer_metrics.publish(key=msg_key, value=json.dumps(metrics_data), topic=topic)
 
@@ -251,6 +262,8 @@ class PluginReceiver():
                              "status":metric_status
                             }
                        }
+        self.logger.info("Publishing response:\nTopic={}\nKey={}\nValue={}"\
+                .format(topic, msg_key, response_msg))
         #Core producer
         self.producer_metrics.publish(key=msg_key, value=json.dumps(response_msg), topic=topic)
 
@@ -269,6 +282,8 @@ class PluginReceiver():
                              "status":metric_status
                             }
                        }
+        self.logger.info("Publishing response:\nTopic={}\nKey={}\nValue={}"\
+                .format(topic, msg_key, response_msg))
         #Core producer
         self.producer_metrics.publish(key=msg_key, value=json.dumps(response_msg), topic=topic)
 
@@ -286,6 +301,8 @@ class PluginReceiver():
                         "tenant_uuid":metric_info['tenant_uuid'],
                         "status":False
                        }
+        self.logger.info("Publishing response:\nTopic={}\nKey={}\nValue={}"\
+                .format(topic, msg_key, response_msg))
         #Core producer
         self.producer_metrics.publish(key=msg_key, value=json.dumps(response_msg), topic=topic)
 
@@ -308,6 +325,8 @@ class PluginReceiver():
                         #"resource_uuid":list_alarm_input['alarm_list_request']['resource_uuid'],
                         "list_alarm_resp":triggered_alarm_list
                        }
+        self.logger.info("Publishing response:\nTopic={}\nKey={}\nValue={}"\
+                .format(topic, msg_key, response_msg))
         #Core producer
         self.producer_alarms.publish(key=msg_key, value=json.dumps(response_msg), topic=topic)
 
@@ -362,9 +381,10 @@ class PluginReceiver():
                         "correlation_id":access_info_req['access_config']['correlation_id'],
                         "status":access_update_status
                        }
-        #To Do - Add producer
-        #self.producer.publish(key=msg_key, value=json.dumps(response_msg), topic=topic)
-        self.producer.publish(topic=topic, messages=json.dumps(response_msg), msg_key=msg_key)
+        self.logger.info("Publishing response:\nTopic={}\nKey={}\nValue={}"\
+                .format(topic, msg_key, response_msg))
+        #Core Add producer
+        self.producer_access_credentials.publish(key=msg_key, value=json.dumps(response_msg), topic=topic)
 
 def main():
     #log.basicConfig(filename='mon_vrops_log.log',level=log.DEBUG)
@@ -375,4 +395,3 @@ def main():
 if __name__ == "__main__":
     main()
 
-