summaryrefslogtreecommitdiff
path: root/src/3rd_party-static/message_broker/include/CMessageBroker.hpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/3rd_party-static/message_broker/include/CMessageBroker.hpp')
-rw-r--r--src/3rd_party-static/message_broker/include/CMessageBroker.hpp108
1 files changed, 0 insertions, 108 deletions
diff --git a/src/3rd_party-static/message_broker/include/CMessageBroker.hpp b/src/3rd_party-static/message_broker/include/CMessageBroker.hpp
deleted file mode 100644
index c542043796..0000000000
--- a/src/3rd_party-static/message_broker/include/CMessageBroker.hpp
+++ /dev/null
@@ -1,108 +0,0 @@
-/**
- * \file CMessageBroker.hpp
- * \brief CMessageBroker singletone class header.
- * \author AKara
- */
-
-#ifndef CMESSAGEBROKER_H
-#define CMESSAGEBROKER_H
-
-#include <string>
-
-#include "CSender.hpp"
-
-/**
- * \namespace NsMessageBroker
- * \brief MessageBroker related functions.
- */
-namespace NsMessageBroker
-{
- /**
- * \enum ErrorCode
- * \brief MessageBroker error codes.
- * \note Value from -32099 to -32000 are reserved for implementation-defined server-errors.
- */
- enum ErrorCode
- {
- CONTROLLER_EXISTS = -32000, /**< Controller has been already registered. */
- SUBSCRIBTION_EXISTS = -32001, /**< Property has been already subscribed by this controller. */
- PARSING_ERROR = -32700, /**< Invalid JSON. An error occurred on the server while parsing the JSON text. */
- INVALID_REQUEST = -32600, /**< The received JSON not a valid MessageBroker Request. */
- METHOD_NOT_FOUND = -32601, /**< The requested remote-procedure does not exist / is not available. */
- INVALID_PARAMS = -32602, /**< Invalid method parameters. */
- INTERNAL_ERROR = -32603, /**< Internal MessageBroker error. */
- UNSUPPORTED_RESOURCE = 2 /**< Controller doesn't registered. */
- };
-
- /**
- * \brief Forward declaration of the private class.
- */
- class CMessageBroker_Private;
-
- /**
- * \class CMessageBroker
- * \brief Singletone CMessageBroker class implementation.
- */
- class CMessageBroker
- {
- public:
- /**
- * \brief Singletone instantiator.
- * \return pointer to CMessageBroker instance.
- */
- static CMessageBroker* getInstance();
-
- /**
- * \brief Destructor.
- */
- ~CMessageBroker();
-
- /**
- * \brief Receive data from TCP server (from client).
- * \param fd FileDescriptor of socket.
- * \param aJSONData JSON string.
- * \param tryHard give up on first JSON parse error or try to workaround it.
- */
- void onMessageReceived(int fd, std::string& aJSONData, bool tryHard);
-
- /**
- * \brief Test of buffer parsing.
- */
- void Test();
-
- /**
- * @brief OnSocketClosed should be called if socked is closed by HMI
- * @param fd socket descriptor
- */
- void OnSocketClosed(const int fd);
-
- /**
- * \brief Starts MessageBroker.
- */
- void startMessageBroker(CSender* pSender);
-
- /**
- * \brief Stops MessageBroker.
- */
- void stopMessageBroker();
-
- /**
- * \brief Method for thread with que processing.
- */
- void* MethodForThread(void * arg);
-
- private:
- /**
- * \brief Private constructor.
- */
- CMessageBroker();
-
- /**
- * \brief The PIMPL of the class.
- */
- CMessageBroker_Private *p;
- };
-} /* namespace NsMessageBroker */
-
-#endif // CMESSAGEBROKER_H
-