|
|
@ -109,7 +109,6 @@ func (och *OnlineHistoryConsumerHandler) Run(channelID int) {
|
|
|
|
log.Debug(triggerID, "msg come to storage center", v.String())
|
|
|
|
log.Debug(triggerID, "msg come to storage center", v.String())
|
|
|
|
if v.MsgData == nil {
|
|
|
|
if v.MsgData == nil {
|
|
|
|
log.NewWarn(triggerID, "msg come to storage center nil", v.String())
|
|
|
|
log.NewWarn(triggerID, "msg come to storage center nil", v.String())
|
|
|
|
panic(v.String())
|
|
|
|
|
|
|
|
continue
|
|
|
|
continue
|
|
|
|
}
|
|
|
|
}
|
|
|
|
isHistory := utils.GetSwitchFromOptions(v.MsgData.Options, constant.IsHistory)
|
|
|
|
isHistory := utils.GetSwitchFromOptions(v.MsgData.Options, constant.IsHistory)
|
|
|
|