ayo/gocommon
8
0
Fork 1
Code Issues Pull Requests Projects Releases Wiki Activity

deleteChannel 오류 수정

Browse Source
This commit is contained in:
mountain
2023-12-25 22:23:46 +09:00
parent 46f7d358ed
commit 29dcca9725
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
session/impl_redis.go
View File

@ -36,7 +36,7 @@ func newProviderWithRedis(ctx context.Context, redisUrl string, ttl time.Duratio
return &provider_redis{ return &provider_redis{
redisClient: redisClient, 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, ttl: ttl,
ctx: ctx, ctx: ctx,
}, nil }, nil
@ -131,7 +131,7 @@ func newConsumerWithRedis(ctx context.Context, redisUrl string, ttl time.Duratio
redisClient: redisClient, 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) sub := redisClient.Subscribe(ctx, deleteChannel)
go func() { go func() {