From 6a0845ff89a25aac60f8e9a34beb31935fd5dad8 Mon Sep 17 00:00:00 2001 From: Marko Kreen Date: Tue, 6 Jul 2010 15:27:50 +0300 Subject: [PATCH] pgq_node.drop_node(): drop queue --- sql/pgq_node/functions/pgq_node.drop_node.sql | 3 +++ 1 file changed, 3 insertions(+) diff --git a/sql/pgq_node/functions/pgq_node.drop_node.sql b/sql/pgq_node/functions/pgq_node.drop_node.sql index 8a1babf2..cf4b4899 100644 --- a/sql/pgq_node/functions/pgq_node.drop_node.sql +++ b/sql/pgq_node/functions/pgq_node.drop_node.sql @@ -63,6 +63,9 @@ begin delete from pgq_node.node_info where queue_name = i_queue_name and node_name = i_node_name; + + perform pgq.drop_queue(queue_name) + from pgq.queue where queue_name = i_queue_name; end if; delete from pgq_node.node_location -- 2.39.5