Bugfix: pass logger to subscription.

blocknative · Aug 7, 2023 · 92283fb · 92283fb
1 parent c4174a7
commit 92283fb
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/stream/transport/redis/redis.go b/stream/transport/redis/redis.go
@@ -37,6 +37,7 @@ func (t *Topic) Publish(ctx context.Context, m transport.Message) error {
 
 func (t *Topic) Subscribe(ctx context.Context) transport.Subscription {
 	return Subscription{
+		Logger:    t.Logger,
 		PubSub:    t.Redis.Subscribe(ctx, t.Name),
 		LocalNode: t.LocalNode,
 	}