Merge pull request #2664 from orb-community/etaques-patch-2

fix: (maestro) reference for redis streams
orb-community · Sep 28, 2023 · fe5ddaf · fe5ddaf
2 parents 47eeaf7 + 6908130
commit fe5ddaf
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/maestro/service.go b/maestro/service.go
@@ -67,8 +67,8 @@ func NewMaestroService(logger *zap.Logger, streamRedisClient *redis.Client, sink
 			Name:      "message_latency_microseconds",
 			Help:      "Total duration of messages processed in microseconds.",
 		}, []string{"method", "sink_id", "owner_id"}))
-	sinkListenerService := rediscons1.NewSinksListenerController(logger, eventService, sinkerRedisClient, sinksGrpcClient)
-	activityListener := rediscons1.NewSinkerActivityListener(logger, eventService, sinkerRedisClient)
+	sinkListenerService := rediscons1.NewSinksListenerController(logger, eventService, streamRedisClient, sinksGrpcClient)
+	activityListener := rediscons1.NewSinkerActivityListener(logger, eventService, streamRedisClient)
 	return &maestroService{
 		logger:              logger,
 		deploymentService:   deploymentService,