1

src/etcp.c

@@ -289,6 +289,12 @@ void etcp_conn_reset(struct ETCP_CONN* etcp) {
         pn_reset(etcp->normalizer);
     }
 
+    queue_resume_callback(etcp->input_queue);
+    queue_resume_callback(etcp->output_queue);
+    queue_resume_callback(etcp->input_send_q);
+    queue_resume_callback(etcp->input_wait_ack);
+    queue_resume_callback(etcp->recv_q);
+
     DEBUG_TRACE(DEBUG_CATEGORY_ETCP, "end");
 }