From 9c348fc891b434190fe4f5ffa556d500f77692d5 Mon Sep 17 00:00:00 2001
From: shoopea <shoopea@siteop.biz>
Date: Mon, 29 Jun 2020 10:48:30 +0200
Subject: [PATCH] test

---
 job.go | 3 +++
 1 file changed, 3 insertions(+)

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")
 			}
 		}
 	}