Feature Request: Conditional reading for PGMQ

[yayahc]

I request an enhancement for the PGMQ extension to support conditional message retrieval. This would allow pulling based on specific attributes directly within the pgmq_read function.

eg: Pull messages with a specific type:
SELECT * FROM pgmq_read('my_queue', 30, 1, '{"type": "A"}');

Thank you for considering this feature request.

[ChuckHend]

Hello @yayahc. To clarify, do you mean that {"type": "A"} would be part of the message, correct? not introducing a new "type" attribute to each message record. E.g. for example, two messages in queue like below, filter for any messages that have the type key with value equal to A:

 msg_id | read_ct |          enqueued_at          |              vt               |             message             
--------+---------+-------------------------------+-------------------------------+---------------------------------
      1 |       0 | 2024-08-06 13:35:08.771765+00 | 2024-08-06 13:35:08.774281+00 | {"type": "A", "hello": "world"}
      2 |       0 | 2024-08-06 13:35:30.572968+00 | 2024-08-06 13:35:30.574291+00 | {"type": "B", "hello": "earth"}

SELECT * FROM pgmq.read('my_queue', 30, 1, '{"type": "A"}'); would return just msg_id = 1.

I think this would be a great feature. There have been some offline discussions about having a feature like this for pgmq.delete() and pgmq.archive() in addition to pgmq.read().

@theory , I wonder if any of the jsonpath projects might come in useful here.

[yayahc]

@ChuckHend exactly, it will be awesome to have this feature

[algora-pbc]

💎 $300 bounty • Tembo

Steps to solve:

1. Start working: Comment /attempt #288 with your implementation plan
2. Submit work: Create a pull request including /claim #288 in the PR body to claim the bounty
3. Receive payment: 100% of the bounty is received 2-5 days post-reward. Make sure you are eligible for payouts

Thank you for contributing to tembo-io/pgmq!

Add a bounty • Share on socials

Attempt	Started (GMT+0)	Solution
🟢 @TomBebb	Oct 18, 2024, 6:39:14 PM	WIP
🟢 @Neptune650	Oct 19, 2024, 12:58:00 AM	#322
🔴 @Abiji-2020	Oct 20, 2024, 6:37:51 AM	#326

[TomBebb]

/attempt #288

Options

• Cancel my attempt

[Neptune650]

/attempt #288

Algora profile	Completed bounties	Tech	Active attempts	Options
@Neptune650	2 bounties from 2 projects	C++, C, Python & more		Cancel attempt

[algora-pbc]

💡 @Neptune650 submitted a pull request that claims the bounty. You can visit your bounty board to reward.

[algora-pbc]

💡 @Abiji-2020 submitted a pull request that claims the bounty. You can visit your bounty board to reward.

[Abiji-2020]

/attempt #288

Algora profile	Completed bounties	Tech	Active attempts	Options
@Abiji-2020	1 tembo bounty + 1 bounty from 1 project	C++, Java, TypeScript & more		Cancel attempt

[algora-pbc]

🎉🎈 @Neptune650 has been awarded $300! 🎈🎊

• Share on socials
• Give feedback