From 30398af36e776ba3bb59bfabf5da978a59e7d6b0 Mon Sep 17 00:00:00 2001 From: Marko Kreen Date: Fri, 7 May 2010 13:23:26 +0300 Subject: [PATCH] pgq_node.register_consumer: update existing reg info, instead erroring out --- sql/pgq_node/functions/pgq_node.register_consumer.sql | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/sql/pgq_node/functions/pgq_node.register_consumer.sql b/sql/pgq_node/functions/pgq_node.register_consumer.sql index 85e06982..b497c407 100644 --- a/sql/pgq_node/functions/pgq_node.register_consumer.sql +++ b/sql/pgq_node/functions/pgq_node.register_consumer.sql @@ -40,7 +40,12 @@ begin where queue_name = i_queue_name and consumer_name = i_consumer_name; if found then - select 405, 'Consumer already registered: ' || i_queue_name + update pgq_node.local_state + set provider_node = i_provider_node, + last_tick_id = i_custom_tick_id + where queue_name = i_queue_name + and consumer_name = i_consumer_name; + select 201, 'Consumer already registered: ' || i_queue_name || '/' || i_consumer_name into ret_code, ret_note; return; end if; -- 2.39.5