1 files changed, 4 insertions, 2 deletions
diff --git a/lib/qpnexus.c b/lib/qpnexus.c
index 5a243d0f..96615253 100644
--- a/lib/qpnexus.c
+++ b/lib/qpnexus.c
@@ -88,9 +88,11 @@ qpn_free(qpn_nexus qpn)
           qps_file_free(qf);
     }
 
-  /* TODO: free qpn->queue */
-  /* TODO: free qpn->mts */
+  if (qpn->queue != NULL)
+    qpn->queue = mqueue_reset(qpn->queue, 1);
 
+  if (qpn->mts != NULL)
+    qpn->mts = mqueue_thread_signal_reset(qpn->mts, 1);
 
   XFREE(MTYPE_QPN_NEXUS, qpn) ;