fixed subscriber_info_watermark_name_fkey violation

(introduced in commit 0466144)

diff --git a/sql/pgq_node/functions/pgq_node.unregister_subscriber.sql b/sql/pgq_node/functions/pgq_node.unregister_subscriber.sql
index 777607e91a9db2df3a7a3f9c5991de1ac2f28898..b7d476e6526ccea6e0395bb6f99a488e70b2981d 100644 (file)
--- a/sql/pgq_node/functions/pgq_node.unregister_subscriber.sql
+++ b/sql/pgq_node/functions/pgq_node.unregister_subscriber.sql
@@ -30,13 +30,13 @@ begin
         return;
     end if;
 
-    perform pgq.unregister_consumer(i_queue_name, n_wm_name);
-    perform pgq.unregister_consumer(i_queue_name, worker_name);
-
     delete from pgq_node.subscriber_info
         where queue_name = i_queue_name
             and subscriber_node = i_remote_node_name;
 
+    perform pgq.unregister_consumer(i_queue_name, n_wm_name);
+    perform pgq.unregister_consumer(i_queue_name, worker_name);
+
     select 200, 'Subscriber unregistered: '||i_remote_node_name
         into ret_code, ret_note;
     return;