| @@ -132,6 +132,7 @@ func (m *SessionManager) startJob(openID string) { | |||
| m.checkOpenID(openID, v) | |||
| s := m.sessions[openID] | |||
| s.data.incomingMsg(v) //<=== main logic for processing each incoming message | |||
| m.sessions[openID] = s | |||
| jobFinished.consumed++ | |||
| default: | |||
| hasJob = false | |||