dapr
/
components-contrib
mirror of https://github.com/dapr/components-contrib.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Remove recover from Redis config store (#2124) 

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Dapr Bot <56698301+dapr-bot@users.noreply.github.com>
This commit is contained in:
Alessandro (Ale) Segala 2022-09-23 21:59:50 -07:00 committed by GitHub
parent d3ec1ff954
commit b566232f67
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 0 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
configuration/redis/redis.go
View File

@ -312,11 +312,6 @@ func (r *ConfigurationStore) doSubscribe(ctx context.Context, req *configuration
}
func (r *ConfigurationStore) handleSubscribedChange(ctx context.Context, req *configuration.SubscribeRequest, handler configuration.UpdateHandler, msg *redis.Message, id string) {
defer func() {
if err := recover(); err != nil {
r.logger.Errorf("panic in handleSubscribedChange(）method and recovered: %s", err)
}
}()
targetKey, err := internal.ParseRedisKeyFromEvent(msg.Channel)
if err != nil {
r.logger.Errorf("parse redis key failed: %s", err)