org.apache.synapse.message.processors.forward

Class ScheduledMessageForwardingProcessor

java.lang.Object

org.apache.synapse.message.processors.AbstractMessageProcessor

org.apache.synapse.message.processors.ScheduledMessageProcessor

org.apache.synapse.message.processors.forward.ScheduledMessageForwardingProcessor

All Implemented Interfaces:

ManagedLifecycle, MessageProcessor, Nameable, SynapseArtifact

public class ScheduledMessageForwardingProcessor
extends ScheduledMessageProcessor

Redelivery processor is the Message processor which implements the Dead letter channel EIP It will Time to time Redeliver the Messages to a given target.

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	BLOCKING_SENDER

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, log, messageStore, name, parameters

Constructor Summary

Constructors

Constructor and Description
ScheduledMessageForwardingProcessor()

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()
int	getSendAttemptCount()
MessageForwardingProcessorView	getView() Return the JMS view of Message Processor
void	incrementSendAttemptCount()
void	init(SynapseEnvironment se) This method should implement the initialization of the implemented parts of the configuration.
boolean	isActive()
void	resetSentAttemptCount()

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

BLOCKING_SENDER

public static final String BLOCKING_SENDER

See Also:

Constant Field Values

Constructor Detail

ScheduledMessageForwardingProcessor

public ScheduledMessageForwardingProcessor()

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

isActive

public boolean isActive()

activate

public void activate()

deactivate

public void deactivate()

getSendAttemptCount

public int getSendAttemptCount()

incrementSendAttemptCount

public void incrementSendAttemptCount()

resetSentAttemptCount

public void resetSentAttemptCount()

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

getView

public MessageForwardingProcessorView getView()

Return the JMS view of Message Processor

Returns:

MessageForwardingProcessorView