1 files changed, 75 insertions, 0 deletions
diff --git a/src/3rd_party-static/message_broker/src/client/mb_client.cpp b/src/3rd_party-static/message_broker/src/client/mb_client.cpp
new file mode 100644
index 0000000000..6342c776a8
--- /dev/null
+++ b/src/3rd_party-static/message_broker/src/client/mb_client.cpp
@@ -0,0 +1,75 @@
+/**
+ * \file mb_client.cpp
+ * \brief MessageBroker client.
+ * \author AKara
+ */
+
+#include <cstring>
+
+#include "mb_client.hpp"
+
+namespace NsMessageBroker
+{
+
+   Client::Client()
+   {
+   }
+
+   Client::Client(const std::string& address, uint16_t port)
+   {
+      m_sock = -1;
+      m_address = address;
+      m_port = port;
+      memset(&m_sockaddr, 0x00, sizeof(struct sockaddr_storage));
+      m_sockaddrlen = 0;
+   }
+
+   Client::~Client()
+   {
+      if(m_sock != -1)
+      {
+        Close();
+      }
+   }
+
+   int Client::GetSocket() const
+   {
+      return m_sock;
+   }
+
+   std::string Client::GetAddress() const
+   {
+      return m_address;
+   }
+
+   void Client::SetAddress(const std::string& address)
+   {
+     m_address = address;
+   }
+
+   void Client::SetPort(uint16_t port)
+   {
+     m_port = port;
+   }
+
+   uint16_t Client::GetPort() const
+   {
+      return m_port;
+   }
+
+   bool Client::Connect()
+   {
+      m_sock = networking::connect(m_protocol, GetAddress(), GetPort(), &m_sockaddr, &m_sockaddrlen);
+
+      return (m_sock != -1) ? true : false;
+   }
+
+   void Client::Close()
+   {
+      shutdown(m_sock, SHUT_RDWR);
+
+      close(m_sock);
+      m_sock = -1;
+   }
+
+} /* namespace NsMessageBroker */