NotificationManager

Methods

(async) consumeAndProcessNotification(messageBroker, documentDb, configManagerObject, calibrationObject)

Description:

• consumes and processes incoming notification messages.

Source:

• Services/NotificationManager.js, line 41

Example

const mdx = require("@nvidia-mdx/web-api-core");
const kafka = new mdx.Utils.Kafka({brokers: ["kafka-broker-url"]}, kafkaConfigMap);
const elastic = new mdx.Utils.Elasticsearch({node: "elasticsearch-url"},databaseConfigMap);
let notificationManagerObject = new mdx.Services.NotificationManager();
let configManagerObject = new mdx.Services.ConfigManager();
let calibrationObject = new mdx.Services.Calibration();
await notificationManagerObject.consumeAndProcessNotification(kafka,elastic,configManagerObject,calibrationObject);

Parameters:

(async) produceCalibrationNotification(messageBroker, input) → {Promise.<Object>}

Description:

• returns a success message when the calibration input message is sent to the message broker.

Source:

• Services/NotificationManager.js, line 24

Example

const mdx = require("@nvidia-mdx/web-api-core");
const kafka = new mdx.Utils.Kafka({brokers: ["kafka-broker-url"]}, kafkaConfigMap);
let input = {timestamp: "2023-01-12T14:20:10.000Z", eventType: "upsert-all", calibration};
let notificationManagerObject = new mdx.Services.NotificationManager();
let result = await notificationManagerObject.produceCalibrationNotification(kafka,input);

Parameters:

Returns:

Type

Promise.<Object>

(async) produceConfigNotification(messageBroker, input) → {Promise.<Object>}

Description:

• returns a success message when the config related input message is sent to the message broker.

Source:

• Services/NotificationManager.js, line 59

Example

const mdx = require("@nvidia-mdx/web-api-core");
const kafka = new mdx.Utils.Kafka({brokers: ["kafka-broker-url"]}, kafkaConfigMap);
let input = {docType: "mdx-mtmc-analytics", timestamp: "2023-01-12T14:20:10.000Z", eventType: "upsert", config};
let notificationManagerObject = new mdx.Services.NotificationManager();
let result = await notificationManagerObject.produceConfigNotification(kafka,input);

Parameters:

Returns:

Type

Promise.<Object>