Class SamplingProcessor
- java.lang.Object
-
- org.apache.synapse.message.processor.impl.AbstractMessageProcessor
-
- org.apache.synapse.message.processor.impl.ScheduledMessageProcessor
-
- org.apache.synapse.message.processor.impl.sampler.SamplingProcessor
-
- All Implemented Interfaces:
ManagedLifecycle
,MessageProcessor
,Nameable
,SynapseArtifact
,org.apache.synapse.task.TaskManagerObserver
public class SamplingProcessor extends ScheduledMessageProcessor
Implements the functionality of the Sampling message processor which injects a message to a given sequence.
-
-
Field Summary
-
Fields inherited from class org.apache.synapse.message.processor.impl.ScheduledMessageProcessor
cronExpression, interval, nonRetryStatusCodes, sender, synapseEnvironment
-
Fields inherited from class org.apache.synapse.message.processor.impl.AbstractMessageProcessor
artifactContainerName, configuration, description, fileName, isEdited, messageConsumers, messageStore, name, parameters, targetEndpoint
-
-
Constructor Summary
Constructors Constructor Description SamplingProcessor()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected org.apache.synapse.task.Task
getTask()
Gives theTask
instance associated with this processor.SamplingProcessorView
getView()
This method is used by Admin service of the message processorvoid
init(SynapseEnvironment se)
This method should implement the initialization of the implemented parts of the configuration.-
Methods inherited from class org.apache.synapse.message.processor.impl.ScheduledMessageProcessor
activate, cleanUpDeactivatedProcessors, cleanupLocalResources, deactivate, destroy, destroy, destroy, getActivated, getIsActivatedParamValue, isActive, isDeactivated, isPaused, isProcessorStartAsDeactivated, isTaskLocationKnown, isThrottling, isThrottling, pauseService, resumeRemotely, resumeService, setParameters, start, stop, update
-
Methods inherited from class org.apache.synapse.message.processor.impl.AbstractMessageProcessor
getArtifactContainerName, getDescription, getFileName, getMessageConsumer, getMessageStoreName, getName, getParameters, getTargetEndpoint, isEdited, setArtifactContainerName, setDescription, setFileName, setIsEdited, setMessageConsumer, setMessageStoreName, setName, setTargetEndpoint
-
-
-
-
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 interfaceManagedLifecycle
- Overrides:
init
in classScheduledMessageProcessor
- Parameters:
se
- SynapseEnvironment to be used for initialization
-
getView
public SamplingProcessorView getView()
This method is used by Admin service of the message processor- Returns:
- The associated MBean.
-
getTask
protected org.apache.synapse.task.Task getTask()
Description copied from class:ScheduledMessageProcessor
Gives theTask
instance associated with this processor.- Specified by:
getTask
in classScheduledMessageProcessor
- Returns:
Task
associated with this processor.
-
-