From b20888d6e5e0c2e750cb1a31d8e20ec592be88e7 Mon Sep 17 00:00:00 2001 From: Marko Kreen Date: Mon, 24 Jan 2011 17:25:33 +0200 Subject: [PATCH] pgq_node.drop_node.sql: on local drop, delete all locations --- sql/pgq_node/functions/pgq_node.drop_node.sql | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/sql/pgq_node/functions/pgq_node.drop_node.sql b/sql/pgq_node/functions/pgq_node.drop_node.sql index 708f6152..fbf13ae7 100644 --- a/sql/pgq_node/functions/pgq_node.drop_node.sql +++ b/sql/pgq_node/functions/pgq_node.drop_node.sql @@ -56,11 +56,14 @@ begin perform pgq.drop_queue(queue_name, true) from pgq.queue where queue_name = i_queue_name; - end if; - delete from pgq_node.node_location - where queue_name = i_queue_name - and node_name = i_node_name; + delete from pgq_node.node_location + where queue_name = i_queue_name; + else + delete from pgq_node.node_location + where queue_name = i_queue_name + and node_name = i_node_name; + end if; select 200, 'Node dropped' into ret_code, ret_note; return; -- 2.39.5