From 29dcca97256ba9dcc18b9d69a4c349a7ce917ea8 Mon Sep 17 00:00:00 2001
From: mountain <mountain@action2quare.com>
Date: Mon, 25 Dec 2023 22:23:46 +0900
Subject: [PATCH] =?UTF-8?q?deleteChannel=20=EC=98=A4=EB=A5=98=20=EC=88=98?=
 =?UTF-8?q?=EC=A0=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 session/impl_redis.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/session/impl_redis.go b/session/impl_redis.go
index e38bc4b..2d8ad9c 100644
--- a/session/impl_redis.go
+++ b/session/impl_redis.go
@@ -36,7 +36,7 @@ func newProviderWithRedis(ctx context.Context, redisUrl string, ttl time.Duratio
 
 	return &provider_redis{
 		redisClient:   redisClient,
-		deleteChannel: fmt.Sprintf("%s_%d", communication_channel_name_prefix, redisClient.Options().DB),
+		deleteChannel: fmt.Sprintf("%s_%d_d", communication_channel_name_prefix, redisClient.Options().DB),
 		ttl:           ttl,
 		ctx:           ctx,
 	}, nil
@@ -131,7 +131,7 @@ func newConsumerWithRedis(ctx context.Context, redisUrl string, ttl time.Duratio
 		redisClient: redisClient,
 	}
 
-	deleteChannel := communication_channel_name_prefix + "_d"
+	deleteChannel := fmt.Sprintf("%s_%d_d", communication_channel_name_prefix, redisClient.Options().DB)
 	sub := redisClient.Subscribe(ctx, deleteChannel)
 
 	go func() {