Supabase Queues

Hey HN, supabase ceo here.

This is a Postgres-native Queue. It's built with the PGMQ extension[0] which the Tembo team have generously licensed their extension with the OSI-compatible PostgreSQL license. PGMQ has API parity with AWS SQS and RSMQ.

Our implementation is compatible with the rest of the supabase stack. With RLS enabled, you can use the client libs to CRUD messages/tasks. eg:

    import { createClient } from '@supabase/supabase-js'

    const queues = createClient(url, key, {
      db: { schema: 'pgmq_public' },
    })
    
    const { data, error } = await queues.rpc('send', {
      queue_name: 'foo',
      message: { hello: 'world' },
    })

We'll be around for any questions

[0] PGMQ: https://github.com/tembo-io/pgmq