package main
import (
    "context"
    "fmt"
    "github.com/craigpastro/pgmq-go"
)
func main() {
    ctx := context.Background()
    pool, err := pgmq.NewPgxPool(ctx, "postgres://postgres:password@localhost:5432/postgres")
    if err != nil {
        panic(err)
    }
    err = pgmq.CreatePGMQExtension(ctx, pool)
    if err != nil {
        panic(err)
    }
    err = pgmq.CreateQueue(ctx, pool, "my_queue")
    if err != nil {
        panic(err)
    }
    // We can perform various queue operations using a transaction.
    tx, err := pool.Begin(ctx)
    if err != nil {
        panic(err)
    }
    id, err := pgmq.Send(ctx, tx, "my_queue", json.RawMessage(`{"foo": "bar"}`))
    if err != nil {
        panic(err)
    }
    msg, err := pgmq.Read(ctx, tx, "my_queue", 30)
    if err != nil {
        panic(err)
    }
    // Archive the message by moving it to the "pgmq.a_<queue_name>" table.
    // Alternatively, you can `Delete` the message, or read and delete in one
    // call by using `Pop`.
    _, err = pgmq.Archive(ctx, tx, "my_queue", id)
    if err != nil {
        panic(err)
    }
    // Commit the transaction.
    err = tx.Commit(ctx)
    if err != nil {
        panic(err)
    }
    // Close the connection pool.
    pool.Close()
}