diff --git a/message/router.go b/message/router.go index 874e10c46..bf00ec67a 100644 --- a/message/router.go +++ b/message/router.go @@ -91,6 +91,10 @@ func NewRouter(config RouterConfig, logger watermill.LoggerAdapter) (*Router, er return nil, errors.Wrap(err, "invalid config") } + if logger == nil { + logger = watermill.NopLogger{} + } + return &Router{ config: config,