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

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

SamplingProcessor()

Method Summary

void	activate()
void	deactivate()
void	destroy() This method should implement the destroying of the implemented parts of the configuration.
protected org.quartz.JobDataMap	getJobDataMap()
protected org.quartz.JobDetail	getJobDetail()
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

getJobDetail

protected org.quartz.JobDetail getJobDetail()

Specified by:

getJobDetail 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()