diff --git a/job.go b/job.go index 981707b..822af0d 100644 --- a/job.go +++ b/job.go @@ -1951,6 +1951,7 @@ func jobGetVault(j Job) { switch id { case cacheObjSubType[`msg_gstock_any_ack`]: + log.Printf("jobGetVault[%d] : Got stock.\n", j.ID64) cwm, err := parseSubTypeMessageGStockAnyAck(m, rule.re) logOnError(err, "jobGetVault : parseSubTypeMessageGStockAnyAck") @@ -1977,6 +1978,7 @@ func jobGetVault(j Job) { case cacheObjSubType[`msg_gstock_rec_req`]: fallthrough case cacheObjSubType[`msg_gstock_part_req`]: + log.Printf("jobGetVault[%d] : Got own request.\n", j.ID64) p.CleanupMsg = append(p.CleanupMsg, *m) setJobPayloadJSON(j.ID64, p) rescheduleJob(j.ID64, 0, time.Unix(maxUnixTimestamp, 0).UTC())