 					return i if obj._id is id
 				return -1
 			dirtyqueue = 0
+			forceQueuereSync = false
 			async.forever((next)->
 				unless r.ready
 					setImmediate -> next()

						if not found
							if findplace(jobId) isnt -1 # update the job
								currentjob = findinque(jobId)
								console.log "re-assign",jobId,currentjob._takenby, "->",host
								currentjob._takenby = host
								currentjob._status = "working"
								currentjob._lastchange = ~~((new Date).getTime() / 1000)

					
					# Inconsistency checks for zmq queue

					if forceQueuereSync or ( ((~~((new Date).getTime() / 1000)) - dirtyqueue > zmqWorking) and status_c.onqueue? and status_c.onqueue isnt s_wk._zmq.pending )
						console.log "Inconsistent Queue", status_c.onqueue, s_wk._zmq.pending, "forced", forceQueuereSync
						zmqids = []
						for item,ix in s_wk._outgoing
							lid = JSON.parse(item[0].toString('utf-8'))._id
