org.apache.synapse.message.processors.sampler

Class SamplingProcessor

java.lang.Object

org.apache.synapse.message.processors.AbstractMessageProcessor

org.apache.synapse.message.processors.ScheduledMessageProcessor

org.apache.synapse.message.processors.sampler.SamplingProcessor

All Implemented Interfaces:

ManagedLifecycle, MessageProcessor, Nameable, SynapseArtifact

public class SamplingProcessor
extends ScheduledMessageProcessor

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.synapse.message.processors.ScheduledMessageProcessor

ScheduledMessageProcessor.State

Field Summary

Fields

Modifier and Type	Field and Description
static String	CONCURRENCY
static String	SEQUENCE

Fields inherited from class org.apache.synapse.message.processors.ScheduledMessageProcessor

cronExpression, interval, PROCESSOR_INSTANCE, quartzConfig, SCHEDULED_MESSAGE_PROCESSOR_GROUP, scheduler, state

Fields inherited from class org.apache.synapse.message.processors.AbstractMessageProcessor

configuration, description, fileName, messageStore, name, parameters

Constructor Summary

Constructors

Constructor and Description
SamplingProcessor()

Method Summary

Modifier and Type	Method and Description
void	activate()
void	deactivate()
void	destroy() This method should implement the destroying of the implemented parts of the configuration.
protected org.quartz.JobBuilder	getJobBuilder()
protected org.quartz.JobDataMap	getJobDataMap()
SamplingProcessorView	getView()
void	init(SynapseEnvironment se) This method should implement the initialization of the implemented parts of the configuration.
boolean	isActive()

Methods inherited from class org.apache.synapse.message.processors.ScheduledMessageProcessor

setParameters, start, stop

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

CONCURRENCY

public static final String CONCURRENCY

See Also:

Constant Field Values

SEQUENCE

public static final String SEQUENCE

See Also:

Constant Field Values

Constructor Detail

SamplingProcessor

public SamplingProcessor()

Method Detail

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 ScheduledMessageProcessor

Parameters:

se - SynapseEnvironment to be used for initialization

getJobBuilder

protected org.quartz.JobBuilder getJobBuilder()

Specified by:

getJobBuilder in class ScheduledMessageProcessor

getJobDataMap

protected org.quartz.JobDataMap getJobDataMap()

Overrides:

getJobDataMap in class ScheduledMessageProcessor

destroy

public void destroy()

Description copied from interface: ManagedLifecycle

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

Specified by:

destroy in interface ManagedLifecycle

Overrides:

destroy in class ScheduledMessageProcessor

isActive

public boolean isActive()

activate

public void activate()

deactivate

public void deactivate()

getView

public SamplingProcessorView getView()