diff --git a/lib/nodes/rtp.c b/lib/nodes/rtp.c
index 5e448f74a..5dd0cad46 100644
--- a/lib/nodes/rtp.c
+++ b/lib/nodes/rtp.c
@@ -160,10 +160,19 @@ int rtp_start(struct node *n)
 
 int rtp_stop(struct node *n)
 {
+	int ret;
 	struct rtp *r = (struct rtp *) n->_vd;
 
 	/*mem_deref(r->rs);*/
 
+	ret = queue_close(&r->recv_queue);
+	if (ret)
+		warn("Problem closing queue");
+
+	ret = queue_destroy(&r->recv_queue);
+	if (ret)
+		warn("Problem destroying queue");
+
 	return io_destroy(&r->io);
 }