From e58b052251ad6b9c89aac62ada6d679b9a49bde1 Mon Sep 17 00:00:00 2001 From: nquidox Date: Fri, 3 Apr 2026 11:21:13 +0300 Subject: [PATCH] logging options added --- options.go | 21 ++++++++++++++++++++- 1 file changed, 20 insertions(+), 1 deletion(-) diff --git a/options.go b/options.go index 37ad97c..3e84f95 100644 --- a/options.go +++ b/options.go @@ -1,6 +1,11 @@ package rabbit -import "time" +import ( + "io" + "log" + "os" + "time" +) type Option func(*options) @@ -39,3 +44,17 @@ func WithConsumerBurstSize(t int) Option { op.consumerBurstSize = t } } + +func WithLogger(l *log.Logger) Option { + return func(op *options) { op.logger = l } +} + +func WithLogging(enabled bool) Option { + return func(op *options) { + if enabled { + op.logger = log.New(os.Stdout, "", log.LstdFlags) + } else { + op.logger = log.New(io.Discard, "", 0) + } + } +}