diff --git a/.gitignore b/.gitignore index a7ec2da0..e4ce344c 100644 --- a/.gitignore +++ b/.gitignore @@ -16,7 +16,7 @@ images/pgmq-pg/Dockerfile META.json Trunk.toml .vscode/ -/results/ -/regression.* -/output_iso/ +pgmq-extension/results/ +pgmq-extension/regression.* +pgmq-extension/output_iso/ .env diff --git a/pgmq-extension/sql/pgmq--1.4.5--1.5.0.sql b/pgmq-extension/sql/pgmq--1.4.5--1.5.0.sql index d74d4070..5754eed5 100644 --- a/pgmq-extension/sql/pgmq--1.4.5--1.5.0.sql +++ b/pgmq-extension/sql/pgmq--1.4.5--1.5.0.sql @@ -85,7 +85,7 @@ BEGIN read_ct = read_ct + 1 FROM cte WHERE m.msg_id = cte.msg_id - RETURNING m.msg_id, m.read_ct, m.enqueued_at, m.vt, m.message, headers; + RETURNING m.msg_id, m.read_ct, m.enqueued_at, m.vt, m.message, m.headers; $QUERY$, qtable, conditional, qtable, make_interval(secs => vt) ); @@ -114,7 +114,7 @@ DECLARE atable TEXT := pgmq.format_table_name(queue_name, 'a'); fq_atable TEXT := 'pgmq.' || atable; BEGIN - RAISE WARNING "drop_queue(queue_name, partitioned) is deprecated and will be removed in PGMQ v2.0. Use drop_queue(queue_name) instead."; + RAISE WARNING 'drop_queue(queue_name, partitioned) is deprecated and will be removed in PGMQ v2.0. Use drop_queue(queue_name) instead.'; PERFORM pgmq.drop_queue(queue_name); @@ -216,7 +216,8 @@ BEGIN read_ct INT DEFAULT 0 NOT NULL, enqueued_at TIMESTAMP WITH TIME ZONE DEFAULT now() NOT NULL, vt TIMESTAMP WITH TIME ZONE NOT NULL, - message JSONB + message JSONB, + headers JSONB ) $QUERY$, qtable @@ -230,7 +231,8 @@ BEGIN enqueued_at TIMESTAMP WITH TIME ZONE DEFAULT now() NOT NULL, archived_at TIMESTAMP WITH TIME ZONE DEFAULT now() NOT NULL, vt TIMESTAMP WITH TIME ZONE NOT NULL, - message JSONB + message JSONB, + headers JSONB ); $QUERY$, atable @@ -286,7 +288,8 @@ BEGIN read_ct INT DEFAULT 0 NOT NULL, enqueued_at TIMESTAMP WITH TIME ZONE DEFAULT now() NOT NULL, vt TIMESTAMP WITH TIME ZONE NOT NULL, - message JSONB + message JSONB, + headers JSONB ) $QUERY$, qtable @@ -300,7 +303,8 @@ BEGIN enqueued_at TIMESTAMP WITH TIME ZONE DEFAULT now() NOT NULL, archived_at TIMESTAMP WITH TIME ZONE DEFAULT now() NOT NULL, vt TIMESTAMP WITH TIME ZONE NOT NULL, - message JSONB + message JSONB, + headers JSONB ); $QUERY$, atable @@ -367,7 +371,8 @@ BEGIN read_ct INT DEFAULT 0 NOT NULL, enqueued_at TIMESTAMP WITH TIME ZONE DEFAULT now() NOT NULL, vt TIMESTAMP WITH TIME ZONE NOT NULL, - message JSONB + message JSONB, + headers JSONB ) PARTITION BY RANGE (%I) $QUERY$, qtable, partition_col @@ -444,7 +449,8 @@ BEGIN enqueued_at TIMESTAMP WITH TIME ZONE DEFAULT now() NOT NULL, archived_at TIMESTAMP WITH TIME ZONE DEFAULT now() NOT NULL, vt TIMESTAMP WITH TIME ZONE NOT NULL, - message JSONB + message JSONB, + headers JSONB ) PARTITION BY RANGE (%I); $QUERY$, atable, a_partition_col