pgq_node.drop_node(): drop queue

diff --git a/sql/pgq_node/functions/pgq_node.drop_node.sql b/sql/pgq_node/functions/pgq_node.drop_node.sql
index 8a1babf2c79579a72ebf378958f2ecff24efa8d7..cf4b48991be80d3691ac6789e4597264e6696441 100644 (file)
--- 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