/**Copyright (c) 2009-2023, NVIDIA CORPORATION & AFFILIATES. All rights reserved.**/
"use strict";
/**
* Class which defines MessageBroker
* @memberof mdxWebApiCore.Utils
* */class MessageBroker{#e;#t;#s;
/**
* Constructor is passed a destructured object as param.
* @param {Object} input - Input object.
* @param {string} input.name
* @param {Object} input.client - Message Broker client
* @param {Map} input.configs
*/
constructor({name:e,client:t,configs:s}={}){this.#e=e,this.#t=t,this.#s=s}
/**
* returns the message broker name.
* @public
* @returns {string}
* @example
* const mdx = require("@nvidia-mdx/web-api-core");
* const kafka = new mdx.Utils.Kafka({brokers: ["kafka-broker-url"]}, kafkaConfigMap);
* let messageBrokerName = kafka.getName();
*/getName(){return this.#e}
/**
* returns the message broker configs.
* @public
* @returns {Map}
* @example
* const mdx = require("@nvidia-mdx/web-api-core");
* const kafka = new mdx.Utils.Kafka({brokers: ["kafka-broker-url"]}, kafkaConfigMap);
* let messageBrokerConfigs = kafka.getConfigs();
*/getConfigs(){return this.#s}
/**
* returns the message broker client.
* @public
* @returns {Object}
* @example
* const mdx = require("@nvidia-mdx/web-api-core");
* const kafka = new mdx.Utils.Kafka({brokers: ["kafka-broker-url"]}, kafkaConfigMap);
* let messageBrokerClient = kafka.getClient();
*/getClient(){return this.#t}}module.exports=MessageBroker;