Add NewDefaultRouter constructor (#493)

ThreeDotsLabs · Sep 23, 2024 · 400f4c5 · 400f4c5
1 parent efb5340
commit 400f4c5
Showing 1 changed file with 13 additions and 1 deletion.
diff --git a/message/router.go b/message/router.go
@@ -91,6 +91,18 @@ func NewRouter(config RouterConfig, logger watermill.LoggerAdapter) (*Router, er
 		return nil, errors.Wrap(err, "invalid config")
 	}
 
+	return newRouter(config, logger), nil
+}
+
+// NewDefaultRouter creates a new Router with default configuration.
+func NewDefaultRouter(logger watermill.LoggerAdapter) *Router {
+	config := RouterConfig{}
+	config.setDefaults()
+
+	return newRouter(config, logger)
+}
+
+func newRouter(config RouterConfig, logger watermill.LoggerAdapter) *Router {
 	if logger == nil {
 		logger = watermill.NopLogger{}
 	}
@@ -116,7 +128,7 @@ func NewRouter(config RouterConfig, logger watermill.LoggerAdapter) (*Router, er
 		logger: logger,
 
 		running: make(chan struct{}),
-	}, nil
+	}
 }
 
 type middleware struct {