diff --git a/sessionManager.go b/sessionManager.go
index 60274d5..c60cf39 100644
--- a/sessionManager.go
+++ b/sessionManager.go
@@ -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