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() {