From dbbdd81a57279774f737a86c9f7b1966b9ecd46c Mon Sep 17 00:00:00 2001
From: Vasiliy Tolstov <v.tolstov@unistack.org>
Date: Tue, 10 Sep 2024 09:30:46 +0300
Subject: [PATCH] fixup redis broker

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
---
 redis.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/redis.go b/redis.go
index bf6c648..c9ff860 100644
--- 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,