Package com.floragunn.searchsupport.jobs.config

Class AbstractJobConfigFactory<JobConfigType extends JobConfig>

java.lang.Object

com.floragunn.searchsupport.jobs.config.AbstractJobConfigFactory<JobConfigType>

All Implemented Interfaces:

JobConfigFactory<JobConfigType>

Direct Known Subclasses:

DefaultJobConfigFactory

public abstract class AbstractJobConfigFactory<JobConfigType extends JobConfig>
extends Object
implements JobConfigFactory<JobConfigType>

Field Summary

Fields

Modifier and Type	Field	Description
protected String	group
protected Class<? extends org.quartz.Job>	jobClass
protected static com.jayway.jsonpath.TypeRef<Map<String,Object>>	MAP_TYPE_REF
protected ScheduleFactory<?>	triggerFactory

Constructor Summary

Constructors

Constructor	Description
AbstractJobConfigFactory(Class<? extends org.quartz.Job> jobClass)
AbstractJobConfigFactory(Class<? extends org.quartz.Job> jobClass, ScheduleFactory<?> triggerFactory)

Method Summary

Modifier and Type	Method	Description
JobConfigType	createFromBytes(String id, org.elasticsearch.common.bytes.BytesReference source, long version)
protected abstract JobConfigType	createFromJsonNode(String id, com.fasterxml.jackson.databind.JsonNode jsonNode, long version)
org.quartz.JobDetail	createJobDetail(JobConfigType jobType)
protected String	getAuthToken(com.fasterxml.jackson.databind.JsonNode jsonNode)
protected String	getDescription(com.fasterxml.jackson.databind.JsonNode jsonNode)
protected Boolean	getDurability(com.fasterxml.jackson.databind.JsonNode jsonNode)
String	getGroup()
Class<? extends org.quartz.Job>	getJobClass()
protected Class<? extends org.quartz.Job>	getJobClass(com.fasterxml.jackson.databind.JsonNode jsonNode)
protected Map<String,Object>	getJobDataMap(com.fasterxml.jackson.databind.JsonNode jsonNode)
protected org.quartz.JobKey	getJobKey(String id, com.fasterxml.jackson.databind.JsonNode jsonNode)
protected List<org.quartz.Trigger>	getTriggers(org.quartz.JobKey jobKey, com.fasterxml.jackson.databind.JsonNode jsonNode)
void	setGroup(String group)
void	setJobClass(Class<? extends org.quartz.Job> jobClass)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

group

protected String group

jobClass

protected Class<? extends org.quartz.Job> jobClass

triggerFactory

protected ScheduleFactory<?> triggerFactory

MAP_TYPE_REF

protected static final com.jayway.jsonpath.TypeRef<Map<String,Object>> MAP_TYPE_REF

Constructor Detail

AbstractJobConfigFactory

public AbstractJobConfigFactory(Class<? extends org.quartz.Job> jobClass,
                                ScheduleFactory<?> triggerFactory)

AbstractJobConfigFactory

public AbstractJobConfigFactory(Class<? extends org.quartz.Job> jobClass)

Method Detail

createFromBytes

public JobConfigType createFromBytes(String id,
                                     org.elasticsearch.common.bytes.BytesReference source,
                                     long version)
                              throws ConfigValidationException

Specified by:

createFromBytes in interface JobConfigFactory<JobConfigType extends JobConfig>

Throws:

ConfigValidationException

createJobDetail

public org.quartz.JobDetail createJobDetail(JobConfigType jobType)

Specified by:

createJobDetail in interface JobConfigFactory<JobConfigType extends JobConfig>

createFromJsonNode

protected abstract JobConfigType createFromJsonNode(String id,
                                                    com.fasterxml.jackson.databind.JsonNode jsonNode,
                                                    long version)
                                             throws ConfigValidationException

Throws:

ConfigValidationException

getJobKey

protected org.quartz.JobKey getJobKey(String id,
                                      com.fasterxml.jackson.databind.JsonNode jsonNode)

getDescription

protected String getDescription(com.fasterxml.jackson.databind.JsonNode jsonNode)

getJobDataMap

protected Map<String,Object> getJobDataMap(com.fasterxml.jackson.databind.JsonNode jsonNode)

getDurability

protected Boolean getDurability(com.fasterxml.jackson.databind.JsonNode jsonNode)

getTriggers

protected List<org.quartz.Trigger> getTriggers(org.quartz.JobKey jobKey,
                                               com.fasterxml.jackson.databind.JsonNode jsonNode)
                                        throws ConfigValidationException

Throws:

ConfigValidationException

getAuthToken

protected String getAuthToken(com.fasterxml.jackson.databind.JsonNode jsonNode)

getJobClass

protected Class<? extends org.quartz.Job> getJobClass(com.fasterxml.jackson.databind.JsonNode jsonNode)

getGroup

public String getGroup()

setGroup

public void setGroup(String group)

getJobClass

public Class<? extends org.quartz.Job> getJobClass()

setJobClass

public void setJobClass(Class<? extends org.quartz.Job> jobClass)