diff --git a/src/vnet/session/session.c b/src/vnet/session/session.c
index f4a9e45..ffe29f9 100644
--- a/src/vnet/session/session.c
+++ b/src/vnet/session/session.c
@@ -1552,6 +1552,8 @@
       return;
     }
 
+  /* App closed so stop propagating dequeue notifications */
+  svm_fifo_clear_deq_ntf (s->tx_fifo);
   s->session_state = SESSION_STATE_CLOSING;
   session_program_transport_ctrl_evt (s, SESSION_CTRL_EVT_CLOSE);
 }