NewConsumerTraceLoggerMid example of Middleware which logs a message into traces.

NewExchangeName placeholder in format "{owner}.{name_you_desire}" example result: "subscriptions.primary".

NewMessage assumes body to be json, for other formats write own factory function.

NewOpenTelemetryMiddleware openTelemetry tracer for rabbitmq.

NewQueueName placeholder in format: "{owner}.{ENV}.{name_you_desire}" example result: "subscriptions.prod.primary" ENV specification help you keep testing queues separate from production, and also run any debugging listening on production data.

Pool is a generic container for keeping rabbitmq clients.

ErrorHandler should handle error during Handler phase and return indicator of `requeue` i.e.

Handler is a function should be some kind of controller.Method where you can handle a kind of business logic or call underlying function and return error which will be handled by underlying ErrorHandler.