A Quartz Scheduler JobStore that uses Redis for persistent storage.
To get Quartz up and running quickly with RedisJobStore
, use the following example to configure your quartz.properties
file:
# setting the scheduler's misfire threshold, in milliseconds
org.quartz.jobStore.misfireThreshold: 60000
# setting the scheduler's JobStore to RedisJobStore
org.quartz.jobStore.class: com.redislabs.quartz.RedisJobStore
# setting your redis host
org.quartz.jobStore.host: <your_redis_host>
# setting your redis port
org.quartz.jobStore.port: <your_redis_port>
# setting your redis password (optional)
org.quartz.jobStore.password: <your_redis_password>
# setting a 'releaseTriggersInterval' will trigger a mechanism for releasing triggers of non-alive schedulers in a given interval, in milliseconds
org.quartz.jobStore.releaseTriggersInterval: 600000
# setting a 'instanceIdFilePath' will release triggers of previous schedulers on startup
org.quartz.jobStore.instanceIdFilePath: /etc/quartz
RedisJobStore
uses the jedis, gson and jedis-lock libraries, so you'll have to download them and add them to your project's classpath or define the relevant Maven dependencies:
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>2.0.0</version>
</dependency>
<dependency>
<groupId>com.google.code.gson</groupId>
<artifactId>gson</artifactId>
<version>2.2.4</version>
</dependency>
<dependency>
<groupId>com.github.jedis-lock</groupId>
<artifactId>jedis-lock</artifactId>
<version>1.0.0</version>
</dependency>
RedisJobStore
attempts to be fully compliant with all of Quartz's features, but currently has some limitations that you should be aware of:
- Only
SimpleTrigger
andCronTrigger
are supported. - For any
GroupMatcher
, only aStringOperatorName.EQUALS
operator is supported. You should note that if your scheduler is designed to compare any group of jobs, triggers, etc. with a pattern-based matcher. RedisJobStore
is designed to use multiple schedulers, but it is not making any use of theorg.quartz.scheduler.instanceName
. The only limitation here is that you should maintain the uniquness of your trigger_group_name:trigger_name, and your job_group_name:job_name and you'll be good to go with multiple schedulers.- A
Scheduler
should be started once on a machine, also to ensure releasing locked triggers of previously crashed schedulers. - Data atomicity-
RedisJobStore
is not using any transaction-like mechanism, but ensures synchronization with global lockings. As a result, if a connection issue occurs during an operation, it might be partially completed. JobDataMap
values are stored and returned as Strings, so you should implement your jobs accordingly.RedisJobStore
is firing triggers only by their fire time, without any cosideration to their priorities at all.
- Quartz's standard JobStores are sometimes considering triggers without a next fire time as tirggers in a WAITING state. As
RedisJobStore
is using redis Sorted Sets to maintain triggers states, using their next fire time as the score, it will consider these triggers as stateless.
To better understand the workflow and the behavior of a Quartz Scheduler using a RedisJobStore
, you may want to review the redis schema in which the RedisJobStore
is making a use of at: /schema/schema.txt