Function ExampleNewConsumer

examples_test.go:16–37

()

var db *sql.DB

func ExampleNewConsumer() {
	slogger := slog.New(slog.NewTextHandler(os.Stdout, &slog.HandlerOptions{Level: slog.LevelDebug}))
	c, err := pgq.NewConsumer(db, "queue_name", &Handler{},
		pgq.WithLockDuration(10*time.Minute),
		pgq.WithPollingInterval(500*time.Millisecond),
		pgq.WithAckTimeout(5*time.Second),
		pgq.WithMessageProcessingReserveDuration(5*time.Second),
		pgq.WithMaxParallelMessages(42),
		pgq.WithMetrics(noop.Meter{}),
		pgq.WithHistoryLimit(24*time.Hour),
		pgq.WithLogger(slogger),
		pgq.WithInvalidMessageCallback(func(ctx context.Context, msg pgq.InvalidMessage, err error) {
			// message Payload and/or Metadata are not JSON object.
			// The message will be discarded.
			slogger.Warn("invalid message",
				"error", err,
				"msg.id", msg.ID,
			)
		}),
	)
	_, _ = c, err
}

func ExampleNewPublisher() {
	hostname, _ := os.Hostname()