From e01cc3a56296518a4ccb70a9ac177828c0c5e237 Mon Sep 17 00:00:00 2001 From: Henry Winkel Date: Wed, 9 Aug 2023 17:03:33 +0200 Subject: [PATCH] FIX:fixed issue with sending message --- src/DirectCommunicationClient.cpp | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/src/DirectCommunicationClient.cpp b/src/DirectCommunicationClient.cpp index 7edc8a0..fd72725 100644 --- a/src/DirectCommunicationClient.cpp +++ b/src/DirectCommunicationClient.cpp @@ -14,10 +14,13 @@ namespace DirectCommunication DirectCommunicationClient::DirectCommunicationClient(ushort port, std::string ServerAddress):port_(port),serverAddress_(ServerAddress) { - context_ = zmq::context_t(1); + context_ = zmq::context_t(); socket_ = zmq::socket_t(context_,zmq::socket_type::client); + LOG_S(INFO)<< "tcp://"+serverAddress_+":"+std::to_string(port_); socket_.connect("tcp://"+serverAddress_+":"+std::to_string(port_)); + isConnected = true; + socket_.set(zmq::sockopt::rcvtimeo,100); socket_.set(zmq::sockopt::sndtimeo,500); @@ -31,6 +34,8 @@ namespace DirectCommunication DirectCommunicationClient::~DirectCommunicationClient() { sendMessage("CLOSE"); + isConnected = false; + stopWorker_ = true; Worker_.join();