Merge pull request #1406 from openmeterio/fix/notification-service-st…

…artup-issues fix: notification service startup issues
openmeterio · Aug 22, 2024 · cdd54aa · cdd54aa
2 parents 6a7f913 + db4d0f5
commit cdd54aa
Showing 1 changed file with 7 additions and 6 deletions.
diff --git a/internal/notification/consumer/consumer.go b/internal/notification/consumer/consumer.go
@@ -38,17 +38,18 @@ func New(opts Options) (*Consumer, error) {
 		Logger:       opts.Logger.WithGroup("balance_threshold_event_handler"),
 	}
 
-	consumer := &Consumer{
-		opts: opts,
-
-		balanceThresholdHandler: balanceThresholdEventHandler,
-	}
-
 	router, err := router.NewDefaultRouter(opts.Router)
 	if err != nil {
 		return nil, err
 	}
 
+	consumer := &Consumer{
+		opts:   opts,
+		router: router,
+
+		balanceThresholdHandler: balanceThresholdEventHandler,
+	}
+
 	_ = router.AddNoPublisherHandler(
 		"balance_consumer_system_events",
 		opts.SystemEventsTopic,