日志
This commit is contained in:
parent
eb6a8777a0
commit
599e4b40d1
@ -3446,12 +3446,12 @@ func ReqFriendTreasureEnd(args []interface{}) error {
|
||||
}
|
||||
|
||||
func ReqKafkaLog(args []interface{}) error {
|
||||
// _, player, buf := ParseArgs(args)
|
||||
// req := &msg.ReqKafkaLog{}
|
||||
// proto.Unmarshal(buf, req)
|
||||
// // player.Kafka(req.Event, map[string]interface{}{
|
||||
// // "data": req.Data,
|
||||
// // })
|
||||
_, player, buf := ParseArgs(args)
|
||||
req := &msg.ReqKafkaLog{}
|
||||
proto.Unmarshal(buf, req)
|
||||
player.Kafka(req.Event, map[string]interface{}{
|
||||
"data": req.Data,
|
||||
})
|
||||
return nil
|
||||
}
|
||||
|
||||
|
||||
Loading…
Reference in New Issue
Block a user