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

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

ScheduledMessageForwardingProcessor()

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()
int	getSendAttemptCount()
BlockingMessageSender	getSender()
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()
void	setSender(BlockingMessageSender sender)

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

getJobDetail

protected org.quartz.JobDetail getJobDetail()

Specified by:

getJobDetail in class ScheduledMessageProcessor

getJobDataMap

protected org.quartz.JobDataMap getJobDataMap()

Overrides:

getJobDataMap in class ScheduledMessageProcessor

getSender

public BlockingMessageSender getSender()

setSender

public void setSender(BlockingMessageSender sender)

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: