Add disconnect function to ZmqReceiver

2026-06-08 05:48:51 +02:00 · 2020-04-02 14:41:08 +02:00
parent 68f75869ea
commit 9cd2413783
2 changed files with 16 additions and 0 deletions
@@ -96,6 +96,20 @@ void ZmqReceiver::connect()
    receiver->connect(connect_address);
 }

+void ZmqReceiver::disconnect()
+{
+    #ifdef DEBUG_OUTPUT
+        using namespace date;
+        using namespace chrono;
+        cout << "[" << system_clock::now() << "]";
+        cout << "[ZmqReceiver::disconnect]";
+        cout << " Disconnect." << endl;
+    #endif
+
+    receiver->disconnect(connect_address);
+    context->close();
+}
+
 pair<shared_ptr<FrameMetadata>, char*> ZmqReceiver::receive()
 {
    if (!receiver) {