diff --git a/job.go b/job.go index c9e703b..533c1cd 100644 --- a/job.go +++ b/job.go @@ -2090,6 +2090,7 @@ func jobGetStash(j Job) { p.CleanupMsg = append(p.CleanupMsg, *m) setJobPayloadJSON(j.ID64, p) rescheduleJob(j.ID64, 0, time.Unix(maxUnixTimestamp, 0).UTC()) + fmt.Printf("jobGetStash : delete exchange req for current client\n") return } else if rule.MsgTypeID64 == cacheObjSubType[`msg_exchange_ack`] { p.CleanupMsg = append(p.CleanupMsg, *m) @@ -2104,10 +2105,12 @@ func jobGetStash(j Job) { break } } + fmt.Printf("jobGetStash : clearing trigger for next client\n") j.Trigger = 0 } else if rule.MsgTypeID64 == cacheObjSubType[`msg_busy`] { p.CleanupMsg = append(p.CleanupMsg, *m) j.Trigger = 0 + fmt.Printf("jobGetStash : client busy => clearing trigger for next client\n") } } }