summaryrefslogtreecommitdiff
path: root/sql/pgq_node
diff options
context:
space:
mode:
authorMarko Kreen2011-11-14 10:43:47 +0000
committerMarko Kreen2011-11-14 10:43:47 +0000
commit2f7196f1b83ee167372250d445d1e403dadc8c36 (patch)
treee12e31a9ce8ef6ec7a8a01e5a1524e83ad01b49d /sql/pgq_node
parent2f3c68a44b8bc06b0b27856ae95465eb9eb8d821 (diff)
pgq_node.register_location: skip insert if location is null
This allows tag-dead for non-existing node.
Diffstat (limited to 'sql/pgq_node')
-rw-r--r--sql/pgq_node/functions/pgq_node.register_location.sql2
1 files changed, 1 insertions, 1 deletions
diff --git a/sql/pgq_node/functions/pgq_node.register_location.sql b/sql/pgq_node/functions/pgq_node.register_location.sql
index aee290f7..ea11e953 100644
--- a/sql/pgq_node/functions/pgq_node.register_location.sql
+++ b/sql/pgq_node/functions/pgq_node.register_location.sql
@@ -42,7 +42,7 @@ begin
dead = i_dead
where queue_name = i_queue_name
and node_name = i_node_name;
- else
+ elsif i_node_location is not null then
insert into pgq_node.node_location (queue_name, node_name, node_location, dead)
values (i_queue_name, i_node_name, i_node_location, i_dead);
end if;