|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.synapse.message.processors.AbstractMessageProcessor org.apache.synapse.message.processors.ScheduledMessageProcessor
public abstract class ScheduledMessageProcessor
Nested Class Summary | |
---|---|
protected static class |
ScheduledMessageProcessor.State
|
Field Summary | |
---|---|
protected String |
cronExpression
A cron expression to run the sampler |
protected long |
interval
The interval at which this processor runs , default value is 1000ms |
static String |
PROCESSOR_INSTANCE
|
protected String |
quartzConfig
The quartz configuration file if specified as a parameter |
static String |
SCHEDULED_MESSAGE_PROCESSOR_GROUP
|
protected org.quartz.Scheduler |
scheduler
The scheduler, run the the processor |
protected ScheduledMessageProcessor.State |
state
Keep the state of the message processor |
Fields inherited from class org.apache.synapse.message.processors.AbstractMessageProcessor |
---|
configuration, description, fileName, log, messageStore, name, parameters |
Constructor Summary | |
---|---|
ScheduledMessageProcessor()
|
Method Summary | |
---|---|
void |
destroy()
This method should implement the destroying of the implemented parts of the configuration. |
protected org.quartz.JobDataMap |
getJobDataMap()
|
protected abstract org.quartz.JobDetail |
getJobDetail()
|
void |
init(SynapseEnvironment se)
This method should implement the initialization of the implemented parts of the configuration. |
void |
setParameters(Map<String,Object> parameters)
Set the Message processor parameters that will be used by the specific implementation |
void |
start()
Start Message Processor |
void |
stop()
Stop MessageProcessor |
Methods inherited from class org.apache.synapse.message.processors.AbstractMessageProcessor |
---|
getDescription, getFileName, getMessageStoreName, getName, getParameters, isStarted, setDescription, setFileName, setMessageStoreName, setName |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final String SCHEDULED_MESSAGE_PROCESSOR_GROUP
public static final String PROCESSOR_INSTANCE
protected org.quartz.Scheduler scheduler
protected long interval
protected String quartzConfig
protected String cronExpression
protected ScheduledMessageProcessor.State state
Constructor Detail |
---|
public ScheduledMessageProcessor()
Method Detail |
---|
public void start()
MessageProcessor
public void stop()
MessageProcessor
public void setParameters(Map<String,Object> parameters)
MessageProcessor
setParameters
in interface MessageProcessor
setParameters
in class AbstractMessageProcessor
public void init(SynapseEnvironment se)
ManagedLifecycle
init
in interface ManagedLifecycle
init
in class AbstractMessageProcessor
se
- SynapseEnvironment to be used for initializationprotected abstract org.quartz.JobDetail getJobDetail()
protected org.quartz.JobDataMap getJobDataMap()
public void destroy()
ManagedLifecycle
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |