jesque
jesque copied to clipboard
gresrun
An implementation of Resque in Java.
项目示例 https://gitee.com/shy323/cloud-jesque ``` ScheduleUtils.cronEnqueue(client, "scheduleService", "print", ScheduleUtils.createCronExpression(triggerTime)); ScheduleUtils.cronEnqueue(client, "scheduleService", "withParams", "0 0/1 * * * ?", 31L, "Cyao"); ScheduleUtils.delayedEnqueue(client, "scheduleService", "withParams", triggerTime, "你好啊", "世界"); ```
If I stop my application and restart it after some time (using the same queue names), it will execute the jobs as many times as it should have run if...
Some time, i got this error when enqueue job. After few minus, everything will back to normal, job can enqueue agian, I don't now where to start to debug this...
``` net.greghaines.jesque.utils.NoSuchConstructorException: class=com.xxx.xxx.xxxx.TestAction args=[6] at net.greghaines.jesque.utils.ReflectionUtils.findConstructor(ReflectionUtils.java:205) ~[jesque-2.1.3.jar:na] at net.greghaines.jesque.utils.ReflectionUtils.createObject(ReflectionUtils.java:147) ~[jesque-2.1.3.jar:na] at net.greghaines.jesque.utils.JesqueUtils.materializeJob(JesqueUtils.java:415) ~[jesque-2.1.3.jar:na] at net.greghaines.jesque.worker.MapBasedJobFactory.materializeJob(MapBasedJobFactory.java:49) ~[jesque-2.1.3.jar:na] at net.greghaines.jesque.worker.WorkerImpl.process(WorkerImpl.java:605) [jesque-2.1.3.jar:na] at net.greghaines.jesque.worker.WorkerImpl.poll(WorkerImpl.java:449) [jesque-2.1.3.jar:na] at net.greghaines.jesque.worker.WorkerImpl.run(WorkerImpl.java:220) [jesque-2.1.3.jar:na] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[na:1.8.0_221] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)...
We need to configure the fail strategy to change behavior on failed jobs. We don't see a way that this is exposed to clients, please expose this functionality
RESET_TO_HIGHEST_PRIORITY Strategy use lua `fromMultiplePriorityQueues.lua`, and it has no operation to push back recurring job (which have exists in `jesque_pop.lua` already)
When I first run a application in my computer, I found the same number of workers as I set in the redis,the key is "${namespace}:workers";but when I restart, I found...
I get `Terminating in response to exception` when jedis throw an `Unable to validate object exception`. I use jstack and there is no worker thread running, how can i resolve...
inFlight key is created in jesque_pop.lua and removed just after task was processed. As far as I understand , this functionality is used to prevent task loss in case worker...
