From 92283fb15d629ef882a90a4d77c3c389c6856776 Mon Sep 17 00:00:00 2001
From: Louis Thibault <l.thibault@sentimens.com>
Date: Mon, 7 Aug 2023 10:22:12 -0400
Subject: [PATCH] Bugfix: pass logger to subscription.

---
 stream/transport/redis/redis.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/stream/transport/redis/redis.go b/stream/transport/redis/redis.go
index d1c5136c..54fdec84 100644
--- 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,
 	}