jesque
jesque copied to clipboard
An implementation of Resque in Java.
If in your runnable/callable you do `System.exit(1);` for example, you end up with an inflight request in redis forever.
I think this should be brought back up #3 and #35. Looks like resque is using heart beats (see `prune_dead_workers`): https://github.com/resque/resque/blob/e0f850f087160362cec1ae3759c7c1e1d9190381/lib/resque/worker.rb#L587
public class Job implements Serializable { private Map vars; private Map unknownFields = new HashMap(); ... } What 's function about the properties that the properties vars and unknownFields .
We probably need a way to check if a job (delayed and recurring as well) exists in the queue. It is something that I find very useful while writing test...
Can we use a lua script to do all types of enqueue? this would reduce network roundtrips by a factor of 2. I am willing to implement this on the...
cool library with some interesting ideas. Ideally, I was trying to create a simple wrapper to hide jesque(and simulate jesque) from a testability perspective. Unfortunately, the design seems to be...
Can we have a JobStore interface instead of using jedis directly in Client and Worker so that we can implement our own JobStore with different storage instead of redis?
@gresrun: Is #90 really fixed? I have seen a similar Exception in my code. I have written a little ugly presentation test to show, that this exception can still be...
Is there a simple way to get the size of the pending jobs for a specific queue, including a sum of all the inflight jobs (from that queue) ?
A worker whose pop returns more than one job? Should be configurable.