org.apache.synapse.message.processors

Class ScheduledMessageProcessor

java.lang.Object

org.apache.synapse.message.processors.AbstractMessageProcessor

org.apache.synapse.message.processors.ScheduledMessageProcessor

All Implemented Interfaces:

ManagedLifecycle, MessageProcessor, Nameable, SynapseArtifact

Direct Known Subclasses:

ResequencingProcessor, SamplingProcessor, ScheduledMessageForwardingProcessor

public abstract class ScheduledMessageProcessor
extends AbstractMessageProcessor

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	ScheduledMessageProcessor.State

Field Summary

Fields

Modifier and Type	Field and Description
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

Constructors

Constructor and Description
ScheduledMessageProcessor()

Method Summary

Methods

Modifier and Type	Method and Description
void	destroy() This method should implement the destroying of the implemented parts of the configuration.
protected abstract org.quartz.JobBuilder	getJobBuilder()
protected org.quartz.JobDataMap	getJobDataMap()
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

SCHEDULED_MESSAGE_PROCESSOR_GROUP

public static final String SCHEDULED_MESSAGE_PROCESSOR_GROUP

See Also:

Constant Field Values

PROCESSOR_INSTANCE

public static final String PROCESSOR_INSTANCE

See Also:

Constant Field Values

scheduler

protected org.quartz.Scheduler scheduler

The scheduler, run the the processor

interval

protected long interval

The interval at which this processor runs , default value is 1000ms

quartzConfig

protected String quartzConfig

The quartz configuration file if specified as a parameter

cronExpression

protected String cronExpression

A cron expression to run the sampler

state

protected ScheduledMessageProcessor.State state

Keep the state of the message processor

Constructor Detail

ScheduledMessageProcessor

public ScheduledMessageProcessor()

Method Detail

start

public void start()

Description copied from interface: MessageProcessor

Start Message Processor

stop

public void stop()

Description copied from interface: MessageProcessor

Stop MessageProcessor

setParameters

public void setParameters(Map<String,Object> parameters)

Description copied from interface: MessageProcessor

Set the Message processor parameters that will be used by the specific implementation

Specified by:

setParameters in interface MessageProcessor

Overrides:

setParameters in class AbstractMessageProcessor

init

public void init(SynapseEnvironment se)

Description copied from interface: ManagedLifecycle

This method should implement the initialization of the implemented parts of the configuration.

Specified by:

init in interface ManagedLifecycle

Overrides:

init in class AbstractMessageProcessor

Parameters:

se - SynapseEnvironment to be used for initialization

getJobBuilder

protected abstract org.quartz.JobBuilder getJobBuilder()

getJobDataMap

protected org.quartz.JobDataMap getJobDataMap()

destroy

public void destroy()

Description copied from interface: ManagedLifecycle

This method should implement the destroying of the implemented parts of the configuration.