test
This commit is contained in:
parent
df71b249ea
commit
e7766d52bb
2
job.go
2
job.go
|
@ -1951,6 +1951,7 @@ func jobGetVault(j Job) {
|
||||||
|
|
||||||
switch id {
|
switch id {
|
||||||
case cacheObjSubType[`msg_gstock_any_ack`]:
|
case cacheObjSubType[`msg_gstock_any_ack`]:
|
||||||
|
log.Printf("jobGetVault[%d] : Got stock.\n", j.ID64)
|
||||||
cwm, err := parseSubTypeMessageGStockAnyAck(m, rule.re)
|
cwm, err := parseSubTypeMessageGStockAnyAck(m, rule.re)
|
||||||
logOnError(err, "jobGetVault : parseSubTypeMessageGStockAnyAck")
|
logOnError(err, "jobGetVault : parseSubTypeMessageGStockAnyAck")
|
||||||
|
|
||||||
|
@ -1977,6 +1978,7 @@ func jobGetVault(j Job) {
|
||||||
case cacheObjSubType[`msg_gstock_rec_req`]:
|
case cacheObjSubType[`msg_gstock_rec_req`]:
|
||||||
fallthrough
|
fallthrough
|
||||||
case cacheObjSubType[`msg_gstock_part_req`]:
|
case cacheObjSubType[`msg_gstock_part_req`]:
|
||||||
|
log.Printf("jobGetVault[%d] : Got own request.\n", j.ID64)
|
||||||
p.CleanupMsg = append(p.CleanupMsg, *m)
|
p.CleanupMsg = append(p.CleanupMsg, *m)
|
||||||
setJobPayloadJSON(j.ID64, p)
|
setJobPayloadJSON(j.ID64, p)
|
||||||
rescheduleJob(j.ID64, 0, time.Unix(maxUnixTimestamp, 0).UTC())
|
rescheduleJob(j.ID64, 0, time.Unix(maxUnixTimestamp, 0).UTC())
|
||||||
|
|
Loading…
Reference in New Issue
Block a user