Class MessageForwardingProcessorView
- java.lang.Object
-
- org.apache.synapse.message.processor.impl.forwarder.MessageForwardingProcessorView
-
- All Implemented Interfaces:
MessageForwardingProcessorViewMBean
public class MessageForwardingProcessorView extends Object implements MessageForwardingProcessorViewMBean
-
-
Constructor Summary
Constructors Constructor Description MessageForwardingProcessorView(ScheduledMessageForwardingProcessor processor)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description 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 idvoid
deleteAll()
Delete all the Messages in Message storeString
getEnvelope(String messageID)
Get the SOAP envelope of the given Message with given IDint
getSize()
boolean
isActive()
Get the Status of the Message Processorboolean
isTaskLocationKnown()
Checks if the task location linked to this Message Processor is knownList<String>
messageIdList()
Get the Message IDs of all stored Messages in the Message storevoid
resend(String messageID)
Resend the Message with the given id return false if fail to re try deliver the messagevoid
resendAll()
try resending all messages stored in the message store via associated endpoints.
-
-
-
Constructor Detail
-
MessageForwardingProcessorView
public MessageForwardingProcessorView(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 interfaceMessageForwardingProcessorViewMBean
- Throws:
Exception
-
deleteAll
public void deleteAll() throws Exception
Description copied from interface:MessageForwardingProcessorViewMBean
Delete all the Messages in Message store- Specified by:
deleteAll
in interfaceMessageForwardingProcessorViewMBean
- 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 interfaceMessageForwardingProcessorViewMBean
- 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 interfaceMessageForwardingProcessorViewMBean
- 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 interfaceMessageForwardingProcessorViewMBean
- 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 interfaceMessageForwardingProcessorViewMBean
- 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 interfaceMessageForwardingProcessorViewMBean
- 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 interfaceMessageForwardingProcessorViewMBean
- 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 interfaceMessageForwardingProcessorViewMBean
-
deactivate
public void deactivate()
Description copied from interface:MessageForwardingProcessorViewMBean
Deactivate the Message Processor This will stop the processing of Messages.- Specified by:
deactivate
in interfaceMessageForwardingProcessorViewMBean
-
isTaskLocationKnown
public boolean isTaskLocationKnown()
Description copied from interface:MessageForwardingProcessorViewMBean
Checks if the task location linked to this Message Processor is known- Specified by:
isTaskLocationKnown
in interfaceMessageForwardingProcessorViewMBean
- Returns:
- true if the task location linked to this Message Processor is known
-
-