diff --git a/workers.go b/workers.go index b3e1ed6..b250716 100644 --- a/workers.go +++ b/workers.go @@ -462,6 +462,12 @@ func SQLIdentifyMsgWorker(id int, objIds <-chan int64) { case objSubTypeMessageStockAck: _, err := parseSubTypeMessageStockAck(m, rule.re) logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing objSubTypeMessageStockAck.") + case objSubTypeMessageGDepositReq: + cwm, err := parseSubTypeMessageGDepositReq(m, rule.re) + logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing objSubTypeMessageGDepositReq.") + case objSubTypeMessageGDepositAck: + cwm, err := parseSubTypeMessageGDepositAck(m, rule.re) + logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing objSubTypeMessageGDepositAck.") default: //log.Printf("SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Unknwon message type in rule %d : %d (%d)\n%s\n", msgParsingRules[i].ID, msgParsingRules[i].MsgTypeID, objId, m.Text) }