- self.plugin_receiver.consume(msg,vim_uuid)
- m_list_alarms.assert_called_with(list_alarms_info)
-
- # Check if publish method called with correct parameters
- m_publish_list_alarm_response.assert_called_with(test_alarm_list, list_alarms_info)
-
-
- @mock.patch.object(monPluginRec.PluginReceiver, 'publish_access_update_response')
- @mock.patch.object(monPluginRec.PluginReceiver, 'update_access_credentials')
- def test_consume_vim_access_request_key(self, m_update_access_credentials,\
- m_publish_access_update_response):
- """Test functionality of consume for vim_access_credentials request key"""
-
- vim_uuid = "f85fc39e-723d-4172-979b-de28b36465bb"
- # Mock a message
- msg = Message()
- msg.topic = "access_credentials"
- msg.key = "vim_access_credentials"
-
- msg.value = json.dumps({"vim_uuid":vim_uuid,"access_config":"access_details"})
- # set return value to mocked method
- m_update_access_credentials.return_value = True
-
- access_info = json.loads(msg.value)
-
- # Call the consume method of plugin_receiver
- self.plugin_receiver.consume(msg,vim_uuid)
-
- # check if mocked method called with required parameters
- m_update_access_credentials.assert_called_with("access_details")