 							when "droperr"
 								act._status = "tofetch"
 								act._lastchange = ~~((new Date).getTime() / 1000)
-							when "onqueue"
-								if s_wk._zmq.pending  is 0
-									# the que lost all elements .. zmq bug
-									act._status = "tosend"
-									act._lastchange = ~~((new Date).getTime() / 1000)
+							# when "onqueue"
+							# 	if s_wk._zmq.pending  is 0
+							# 		# the que lost all elements .. zmq bug
+							# 		act._status = "tosend"
+							# 		act._lastchange = ~~((new Date).getTime() / 1000)
 							when "errored"
 								if act.exec?
 									act._status = "tosend"

								return false if todelete.indexOf(ix) isnt -1
								return true
						# on Que but not on zmq
						for item in workque when item._status = "onqueue"
							found = false
							for zItem in zmqids when zItem[0] is item._id
								found = true
							if !found
								console.log "requeueing",item._id
								item._status = "tosend"
								item._lastchange = ~~((new Date).getTime() / 1000)
					setImmediate -> next()
			,(err)->
				#it will never stop

						#console.log output.join(" | "), output.length,".--"
						#process.stdout.clearLine()
						output.push "zmq : " + s_wk._zmq.pending
						output.push "mem : " + (if os.freemem() < (config.minMem * 1048576) then "Ok" else "notOk")
						if canprogress
							process.stdout.cursorTo(60)
							process.stdout.write output.join(" | ")
