org.apache.synapse.message.processors.forward
Class MessageForwardingProcessorView

java.lang.Object
  org.apache.synapse.message.processors.forward.MessageForwardingProcessorView

All Implemented Interfaces:

MessageForwardingProcessorViewMBean

public class MessageForwardingProcessorView
extends Object
implements MessageForwardingProcessorViewMBean

Constructor Summary

MessageForwardingProcessorView(MessageStore messageStore, BlockingMessageSender sender, ScheduledMessageForwardingProcessor processor)

Method Summary

void	activate() Activate the Message Processor.
void	deactivate() Deactivate the Message Processor This will stop the processing of Messages.
void	delete(String messageID) Delete the Message with Given id
void	deleteAll() Delete all the Messages in Message store
String	getEnvelope(String messageID) Get the SOAP envelope of the given Message with given ID
int	getSize()
boolean	isActive() Get the Status of the Message Processor
List<String>	messageIdList() Get the Message IDs of all stored Messages in the Message store
void	resend(String messageID) Resend the Message with the given id return false if fail to re try deliver the message
void	resendAll() try resending all messages stored in the message store via associated endpoints.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MessageForwardingProcessorView

public MessageForwardingProcessorView(MessageStore messageStore,
                                      BlockingMessageSender sender,
                                      ScheduledMessageForwardingProcessor processor)
                               throws Exception

Throws:

Exception

Method Detail

resendAll

public void resendAll()
               throws Exception

Description copied from interface: MessageForwardingProcessorViewMBean

try resending all messages stored in the message store via associated endpoints.

Specified by:

resendAll in interface MessageForwardingProcessorViewMBean

Throws:

Exception

deleteAll

public void deleteAll()
               throws Exception

Description copied from interface: MessageForwardingProcessorViewMBean

Delete all the Messages in Message store

Specified by:

deleteAll in interface MessageForwardingProcessorViewMBean

Throws:

Exception

messageIdList

public List<String> messageIdList()
                           throws Exception

Description copied from interface: MessageForwardingProcessorViewMBean

Get the Message IDs of all stored Messages in the Message store

Specified by:

messageIdList in interface MessageForwardingProcessorViewMBean

Returns:

a list of message ID values

Throws:

Exception

resend

public void resend(String messageID)
            throws Exception

Description copied from interface: MessageForwardingProcessorViewMBean

Resend the Message with the given id return false if fail to re try deliver the message

Specified by:

resend in interface MessageForwardingProcessorViewMBean

Parameters:

messageID - ID of the message to be resent

Throws:

Exception

delete

public void delete(String messageID)
            throws Exception

Description copied from interface: MessageForwardingProcessorViewMBean

Delete the Message with Given id

Specified by:

delete in interface MessageForwardingProcessorViewMBean

Parameters:

messageID - ID of the message to be deleted

Throws:

Exception

getEnvelope

public String getEnvelope(String messageID)
                   throws Exception

Description copied from interface: MessageForwardingProcessorViewMBean

Get the SOAP envelope of the given Message with given ID

Specified by:

getEnvelope in interface MessageForwardingProcessorViewMBean

Parameters:

messageID - ID of the message to be returned

Returns:

the SOAP envelope content as a string

Throws:

Exception

getSize

public int getSize()

Specified by:

getSize in interface MessageForwardingProcessorViewMBean

Returns:

the number of Messages stored in the store.

isActive

public boolean isActive()

Description copied from interface: MessageForwardingProcessorViewMBean

Get the Status of the Message Processor

Specified by:

isActive in interface MessageForwardingProcessorViewMBean

Returns:

status of the Processor

activate

public void activate()

Description copied from interface: MessageForwardingProcessorViewMBean

Activate the Message Processor. This will resume processing the Messages if its in deactivated state and reset the Send attempt count.

Specified by:

activate in interface MessageForwardingProcessorViewMBean

deactivate

public void deactivate()

Description copied from interface: MessageForwardingProcessorViewMBean

Deactivate the Message Processor This will stop the processing of Messages.

Specified by:

deactivate in interface MessageForwardingProcessorViewMBean