diff --git a/workers.go b/workers.go index 3dc98b6..32575eb 100644 --- a/workers.go +++ b/workers.go @@ -525,7 +525,7 @@ func SQLIdentifyMsgWorker(id int, objIds <-chan int64) { logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : insertMsgTributesStats") case cacheObjSubType[`msg_shop_main_req`]: case cacheObjSubType[`msg_shop_main_ack`]: - _, err := parseSubTypeMessageShopMainAck(m, rule.re) + cwm, err := parseSubTypeMessageShopMainAck(m, rule.re) logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing cacheObjSubType[`msg_shop_main_ack`]") err = insertMsgShopMainAck(cwm) logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : insertMsgShopMainAck")