Class FailoverMessageForwardingProcessorView
- java.lang.Object
-
- org.apache.synapse.message.processor.impl.failover.FailoverMessageForwardingProcessorView
-
- All Implemented Interfaces:
FailoverMessageForwardingProcessorViewMBean
public class FailoverMessageForwardingProcessorView extends Object implements FailoverMessageForwardingProcessorViewMBean
-
-
Constructor Summary
Constructors Constructor Description FailoverMessageForwardingProcessorView(FailoverScheduledMessageForwardingProcessor 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.
-
-
-
Constructor Detail
-
FailoverMessageForwardingProcessorView
public FailoverMessageForwardingProcessorView(FailoverScheduledMessageForwardingProcessor processor) throws Exception
- Throws:
Exception
-
-
Method Detail
-
resendAll
public void resendAll() throws Exception
Description copied from interface:FailoverMessageForwardingProcessorViewMBean
try resending all messages stored in the message store.- Specified by:
resendAll
in interfaceFailoverMessageForwardingProcessorViewMBean
- Throws:
Exception
-
deleteAll
public void deleteAll() throws Exception
Description copied from interface:FailoverMessageForwardingProcessorViewMBean
Delete all the Messages in Message store- Specified by:
deleteAll
in interfaceFailoverMessageForwardingProcessorViewMBean
- Throws:
Exception
-
messageIdList
public List<String> messageIdList() throws Exception
Description copied from interface:FailoverMessageForwardingProcessorViewMBean
Get the Message IDs of all stored Messages in the Message store- Specified by:
messageIdList
in interfaceFailoverMessageForwardingProcessorViewMBean
- Returns:
- a list of message ID values
- Throws:
Exception
-
resend
public void resend(String messageID) throws Exception
Description copied from interface:FailoverMessageForwardingProcessorViewMBean
Resend the Message with the given id return false if fail to re try deliver the message- Specified by:
resend
in interfaceFailoverMessageForwardingProcessorViewMBean
- Parameters:
messageID
- ID of the message to be resent- Throws:
Exception
-
delete
public void delete(String messageID) throws Exception
Description copied from interface:FailoverMessageForwardingProcessorViewMBean
Delete the Message with Given id- Specified by:
delete
in interfaceFailoverMessageForwardingProcessorViewMBean
- Parameters:
messageID
- ID of the message to be deleted- Throws:
Exception
-
getEnvelope
public String getEnvelope(String messageID) throws Exception
Description copied from interface:FailoverMessageForwardingProcessorViewMBean
Get the SOAP envelope of the given Message with given ID- Specified by:
getEnvelope
in interfaceFailoverMessageForwardingProcessorViewMBean
- 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 interfaceFailoverMessageForwardingProcessorViewMBean
- Returns:
- the number of Messages stored in the store.
-
isActive
public boolean isActive()
Description copied from interface:FailoverMessageForwardingProcessorViewMBean
Get the Status of the Message Processor- Specified by:
isActive
in interfaceFailoverMessageForwardingProcessorViewMBean
- Returns:
- status of the Processor
-
activate
public void activate()
Description copied from interface:FailoverMessageForwardingProcessorViewMBean
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 interfaceFailoverMessageForwardingProcessorViewMBean
-
deactivate
public void deactivate()
Description copied from interface:FailoverMessageForwardingProcessorViewMBean
Deactivate the Message Processor This will stop the processing of Messages.- Specified by:
deactivate
in interfaceFailoverMessageForwardingProcessorViewMBean
-
isTaskLocationKnown
public boolean isTaskLocationKnown()
Description copied from interface:FailoverMessageForwardingProcessorViewMBean
Checks if the task location linked to this Message Processor is known- Specified by:
isTaskLocationKnown
in interfaceFailoverMessageForwardingProcessorViewMBean
- Returns:
- true if the task location linked to this Message Processor is known
-
-