fixup redis broker

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2024-09-10 09:30:46 +03:00 · 2024-09-10 09:30:46 +03:00 · dbbdd81a57
commit dbbdd81a57
parent c7b6158602
1 changed files with 1 additions and 0 deletions
--- a/redis.go
+++ b/redis.go
@ -225,6 +225,7 @@ func (b *Broker) BatchSubscribe(ctx context.Context, topic string, handler broke
 // Subscribe returns a broker.Subscriber for the topic and handler
 func (b *Broker) Subscribe(ctx context.Context, topic string, handler broker.Handler, opts ...broker.SubscribeOption) (broker.Subscriber, error) {
 	s := &Subscriber{
+		ctx:    ctx,
 		topic:  topic,
 		handle: handler,
 		opts:   b.opts,