From 334d81a1abd6a9bcbd6815ab9ec07c7a2fdcdf37 Mon Sep 17 00:00:00 2001
From: Alexey Rybalchenko <alexryba@gmail.com>
Date: Wed, 19 Feb 2020 16:52:50 +0100
Subject: [PATCH] SDK: Unsubscribe in the Topology destructor

---
 fairmq/sdk/Topology.h | 14 +++++++++++---
 1 file changed, 11 insertions(+), 3 deletions(-)

diff --git a/fairmq/sdk/Topology.h b/fairmq/sdk/Topology.h
index 937ceb1e..e6f6ee99 100644
--- a/fairmq/sdk/Topology.h
+++ b/fairmq/sdk/Topology.h
@@ -39,6 +39,7 @@
 #include <set>
 #include <stdexcept>
 #include <string>
+#include <thread>
 #include <unordered_map>
 #include <utility>
 #include <vector>
@@ -250,11 +251,18 @@ class BasicTopology : public AsioBase<Executor, Allocator>
     BasicTopology(BasicTopology&&) = default;
     BasicTopology& operator=(BasicTopology&&) = default;
 
+    void UnsubscribeFromStateChanges()
+    {
+        using namespace fair::mq::sdk::cmd;
+
+        fDDSSession.SendCommand(Cmds(make<UnsubscribeFromStateChange>()).Serialize());
+        // give dds a chance to complete request, TODO: track each individual task and its subscription status
+        std::this_thread::sleep_for(std::chrono::milliseconds(100));
+    }
+
     ~BasicTopology()
     {
-        
-
-
+        UnsubscribeFromStateChanges();
 
         std::lock_guard<std::mutex> lk(fMtx);
         fDDSSession.UnsubscribeFromCommands();