diff --git a/job.go b/job.go index b5439ab..24bd161 100644 --- a/job.go +++ b/job.go @@ -2080,6 +2080,11 @@ func jobGetStash(j Job) { err = json.Unmarshal(j.Payload, &p) logOnError(err, "jobGetStash : Unmarshal payload") + fmt.Printf("jobGetStash : Start ..\n") + fmt.Printf("jobGetStash : Trigger : %d\n", j.Trigger) + fmt.Printf("jobGetStash : UserID64 : %d\n", j.UserID64) + fmt.Printf("jobGetStash : len(p.ClientID64) : %d\n", len(p.ClientID64)) + if j.Trigger > 0 { m, err := getObjMsg(j.Trigger) logOnError(err, "jobGetStash : getObjMsg("+strconv.FormatInt(j.Trigger, 10)+")") @@ -2094,7 +2099,7 @@ func jobGetStash(j Job) { return } else if rule.MsgTypeID64 == cacheObjSubType[`msg_exchange_ack`] { p.CleanupMsg = append(p.CleanupMsg, *m) - fmt.Printf("jobGetStash : finding client\n") + fmt.Printf("jobGetStash : Ack received : deleting current client\n") for k, v := range p.ClientID64 { fmt.Printf("jobGetStash : testing client [%d] : %d\n", k, v) if v == j.UserID64 {