diff --git a/src/etcp.c b/src/etcp.c
index f7e30478..8f88c42f 100644
--- a/src/etcp.c
+++ b/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");
 }