pgq_node: workarounds for bandaid casts

diff --git a/sql/pgq_node/functions/pgq_node.set_consumer_completed.sql b/sql/pgq_node/functions/pgq_node.set_consumer_completed.sql
index 0c1bcc46c74e3196f3731ffb944c0dfcb7e3b52e..44c15a5ac928d87495c3c639d1a71cd6ecfd552e 100644 (file)
--- a/sql/pgq_node/functions/pgq_node.set_consumer_completed.sql
+++ b/sql/pgq_node/functions/pgq_node.set_consumer_completed.sql
@@ -24,7 +24,7 @@ begin
      where queue_name = i_queue_name
        and consumer_name = i_consumer_name;
     if found then
-        select 100, 'Consumer ' || i_consumer_name || ' compleded tick = ' || i_tick_id
+        select 100, 'Consumer ' || i_consumer_name || ' compleded tick = ' || i_tick_id::text
             into ret_code, ret_note;
     else
         select 404, 'Consumer not known: '

diff --git a/sql/pgq_node/functions/pgq_node.set_global_watermark.sql b/sql/pgq_node/functions/pgq_node.set_global_watermark.sql
index 00a9bab5d0a14ed7b8388dd6724c3ee3af5dff9c..9150ad766174c532a1dabd3a819d40c6c29c4cc9 100644 (file)
--- a/sql/pgq_node/functions/pgq_node.set_global_watermark.sql
+++ b/sql/pgq_node/functions/pgq_node.set_global_watermark.sql
@@ -70,7 +70,7 @@ begin
             and t.tick_queue = q.queue_id
             and t.tick_id = _wm;
         if not found then
-            select 200, 'Skipping global watermark update to ' || _wm
+            select 200, 'Skipping global watermark update to ' || _wm::text
                 into ret_code, ret_note;
             return;
         end if;
@@ -83,7 +83,7 @@ begin
         return;
     end if;
 
-    select 200, 'Global watermark set to ' || _wm
+    select 200, 'Global watermark set to ' || _wm::text
         into ret_code, ret_note;
     return;
 end;

diff --git a/sql/pgq_node/functions/pgq_node.set_subscriber_watermark.sql b/sql/pgq_node/functions/pgq_node.set_subscriber_watermark.sql
index b492e9ea588535a08bafeb908054fefa3c4c55ff..32450c6bdd4c67e1779f97744c916a9d88e552d1 100644 (file)
--- a/sql/pgq_node/functions/pgq_node.set_subscriber_watermark.sql
+++ b/sql/pgq_node/functions/pgq_node.set_subscriber_watermark.sql
@@ -45,7 +45,7 @@ begin
 
     perform pgq.register_consumer_at(i_queue_name, wm_name, i_watermark);
 
-    select 200, wm_name || ' set to ' || i_watermark
+    select 200, wm_name || ' set to ' || i_watermark::text
         into ret_code, ret_note;
     return;
 end;