diff --git a/redis.go b/redis.go
index d2b03f8..27ecb72 100644
--- 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