1 files changed, 113 insertions, 0 deletions
diff --git a/src/3rd_party-static/MessageBroker/include/CMessageBrokerRegistry.hpp b/src/3rd_party-static/MessageBroker/include/CMessageBrokerRegistry.hpp
new file mode 100644
index 0000000000..001f978bbf
--- /dev/null
+++ b/src/3rd_party-static/MessageBroker/include/CMessageBrokerRegistry.hpp
@@ -0,0 +1,113 @@
+#ifndef CMESSAGEBROKERREGISTRY_H
+#define CMESSAGEBROKERREGISTRY_H
+
+#include <map>
+#include <vector>
+#include <iostream>
+#include <string>
+#include "utils/lock.h"
+
+/**
+ * \namespace NsMessageBroker
+ * \brief MessageBroker related functions.
+ */ 
+namespace NsMessageBroker 
+{
+
+   /**
+   * \class CMessageBrokerRegistry
+   * \brief Singletone CMessageBrokerRegistry class implementation.
+   */
+   class CMessageBrokerRegistry
+   {
+   public:
+      /**
+      * \brief Singletone instantiator.
+      * \return pointer to CMessageBroker instance
+      */
+      static CMessageBrokerRegistry* getInstance();
+
+      /**
+      * \brief Destructor.
+      */
+      ~CMessageBrokerRegistry();
+
+      /**
+      * \brief adds controller to the registry.
+      * \param fd file descriptor of controller.
+      * \param name name of controller.
+      * \return false if already exist.
+      */
+      bool addController(int fd, std::string name);
+
+      /**
+      * \brief deletes controller from the registry.
+      * \param name name of controller.
+      */
+      void deleteController(std::string name);
+
+      /**
+      * \brief Remove all controllers by descriptor
+      * \param fd descriptor
+      */
+      void removeControllersByDescriptor(const int fd);
+
+      /**
+      * \brief Remove all subscribers by descriptor
+      * \param fd descriptor
+      */
+      void removeSubscribersByDescriptor(const int fd);
+
+      /**
+      * \brief adds notification subscriber to the registry.
+      * \param fd file descriptor of controller.
+      * \param name name of property which should be observed.
+      * \return false if already exist.
+      */
+      bool addSubscriber(int fd, std::string name);
+
+      /**
+      * \brief deletes notification subscriber from the registry.
+      * \param fd file descriptor of controller.
+      * \param name name of property which should be observed.
+      */
+      void deleteSubscriber(int fd, std::string name);
+
+      /**
+      * \brief gets controller fd from the registry by name.
+      * \param name name of controller.
+      * \return file descriptor of controller.
+      */
+      int getDestinationFd(std::string name);
+
+      /**
+      * \brief gets subscribers fd's.
+      * \param name name of property.
+      * \param result vector for results.
+      * \return count of subscribers.
+      */
+      int getSubscribersFd(std::string name, std::vector<int>& result);
+   private:
+      /**
+      * \brief Constructor.
+      */
+      CMessageBrokerRegistry();
+
+      /**
+      * \brief Map to store controllers information like ComponentName:socketFd.
+      * For example PhoneController:1080
+      */
+      std::map <std::string, int> mControllersList;
+      sync_primitives::Lock mControllersListLock;
+
+      /**
+      * \brief Map to store subscribers information like ComponentName.PropertyName:socketFd:.
+      * For example PhoneController.onPhoneBookChanged:1080
+      */
+      std::multimap <std::string, int> mSubscribersList;
+      sync_primitives::Lock mSubscribersListLock;
+   };
+} /* namespace NsMessageBroker */
+
+#endif // CMESSAGEBROKERREGISTRY_H
+