Revert "NewWebsocketHandler에 redisClient를 받음"
This reverts commit db3b0c8d08.
This commit is contained in:
@ -156,13 +156,13 @@ func init() {
|
|||||||
gob.Register([]any{})
|
gob.Register([]any{})
|
||||||
}
|
}
|
||||||
|
|
||||||
func NewWebsocketHandler(consumer session.Consumer, redisUri string) (*WebsocketHandler, error) {
|
func NewWebsocketHandler(consumer session.Consumer) (*WebsocketHandler, error) {
|
||||||
var config wsConfig
|
var config wsConfig
|
||||||
if err := gocommon.LoadConfig(&config); err != nil {
|
if err := gocommon.LoadConfig(&config); err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|
||||||
redisSync, err := gocommon.NewRedisClient(redisUri)
|
redisSync, err := gocommon.NewRedisClient(config.Redis["wshandler"])
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user