1 files changed, 2 insertions, 0 deletions
diff --git a/contrib/Socket.cpp b/contrib/Socket.cpp
index c876f32..7ff6b5e 100644
--- a/contrib/Socket.cpp
+++ b/contrib/Socket.cpp
@@ -936,10 +936,12 @@ void TCPReceiveServer::process()
                 sock.close();
                 // TODO replace fprintf
                 fprintf(stderr, "TCP Receiver restarted after error: %s\n", e.what());
+                m_queue.push(make_shared<TCPReceiveMessageDisconnected>());
             }
 
             if (num_timeouts > max_num_timeouts) {
                 sock.close();
+                m_queue.push(make_shared<TCPReceiveMessageDisconnected>());
             }
         }
     }