test
This commit is contained in:
parent
9c348fc891
commit
08530a9759
1
job.go
1
job.go
@ -2135,6 +2135,7 @@ func jobGetStash(j Job) {
|
|||||||
setJobCallback(j.ID64, userID64, cacheObjSubType[`msg_exchange_req`])
|
setJobCallback(j.ID64, userID64, cacheObjSubType[`msg_exchange_req`])
|
||||||
setJobCallback(j.ID64, userID64, cacheObjSubType[`msg_exchange_ack`])
|
setJobCallback(j.ID64, userID64, cacheObjSubType[`msg_exchange_ack`])
|
||||||
setJobCallback(j.ID64, userID64, cacheObjSubType[`msg_busy`])
|
setJobCallback(j.ID64, userID64, cacheObjSubType[`msg_busy`])
|
||||||
|
setJobPayloadJSON(j.ID64, p)
|
||||||
rescheduleJob(j.ID64, 0, time.Unix(maxUnixTimestamp, 0).UTC())
|
rescheduleJob(j.ID64, 0, time.Unix(maxUnixTimestamp, 0).UTC())
|
||||||
clientSendCWMsgDelay(userID64, "⚖Exchange", busyUntil.Add(2*time.Second).Sub(time.Now().UTC()))
|
clientSendCWMsgDelay(userID64, "⚖Exchange", busyUntil.Add(2*time.Second).Sub(time.Now().UTC()))
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user