Class FailoverScheduledMessageForwardingProcessor
- java.lang.Object
-
- org.apache.synapse.message.processor.impl.AbstractMessageProcessor
-
- org.apache.synapse.message.processor.impl.ScheduledMessageProcessor
-
- org.apache.synapse.message.processor.impl.failover.FailoverScheduledMessageForwardingProcessor
-
- All Implemented Interfaces:
ManagedLifecycle
,MessageProcessor
,Nameable
,SynapseArtifact
,org.apache.synapse.task.TaskManagerObserver
public class FailoverScheduledMessageForwardingProcessor extends ScheduledMessageProcessor
Redelivery processor will Time to time Redeliver the Messages to a given message store.
-
-
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 FailoverScheduledMessageForwardingProcessor()
-
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.FailoverMessageForwardingProcessorView
getView()
This method is used by back end 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 FailoverMessageForwardingProcessorView getView()
This method is used by back end 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.
-
-