fixup redis broker

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2024-09-10 09:08:01 +03:00
1 changed files with 1 additions and 0 deletions
--- a/redis.go
+++ b/redis.go
@@ -264,6 +264,7 @@ func (b *Broker) configure() error {
 	c := redis.NewUniversalClient(redisOptions)
 	setTracing(c, b.opts.Tracer)

+	b.cli = c
 	b.statsMeter()

 	return nil