Exposing pgmq queues via migration with RLS
Hey everyone, I’m working with pgmq queues in Supabase. I have a cron job calling an Edge Function and I want to expose queues via PostgREST using a schema migration instead of the Supabase Dashboard.
I also need RLS on the queues so I can safely do this:
const { error: deleteError } = await supabase
.schema('pgmq_public')
.rpc('delete', {
queue_name: QUEUE_NAME,
msg_id: message.msg_id,
});
Has anyone done this before? Any examples of exposing pgmq queues via migration and setting up RLS would be really helpful.
I also need RLS on the queues so I can safely do this:
const { error: deleteError } = await supabase
.schema('pgmq_public')
.rpc('delete', {
queue_name: QUEUE_NAME,
msg_id: message.msg_id,
});
Has anyone done this before? Any examples of exposing pgmq queues via migration and setting up RLS would be really helpful.
