Method RegisterHandler

internal/base/queue/queue.go:34–34

RegisterHandler sets the handler function for processing messages.

(handler func(ctx context.Context, msg T) error)

	// RegisterHandler sets the handler function for processing messages.
	RegisterHandler(handler func(ctx context.Context, msg T) error)

	// Close gracefully shuts down the queue, waiting for pending messages to be processed.
	Close()