com.adaptris.core

Class DefaultFailedMessageRetrierJmx

java.lang.Object

com.adaptris.core.runtime.ChildRuntimeInfoComponentImpl

com.adaptris.core.DefaultFailedMessageRetrierJmx

All Implemented Interfaces:

DefaultFailedMessageRetrierJmxMBean, BaseComponentMBean, ChildRuntimeInfoComponent, ChildRuntimeInfoComponentMBean, RuntimeInfoComponent

public class DefaultFailedMessageRetrierJmx
extends ChildRuntimeInfoComponentImpl
implements DefaultFailedMessageRetrierJmxMBean

Field Summary

Fields inherited from class com.adaptris.core.runtime.ChildRuntimeInfoComponentImpl

log

Method Summary

Modifier and Type	Method and Description
RuntimeInfoComponent	getParentRuntimeInfoComponent()
protected java.lang.String	getType()
boolean	retryMessage(java.io.File file) Retry a message that has been written to the filesystem.
boolean	retryMessage(SerializableMessage msg) Retry a message.
protected java.lang.String	uniqueId()

Methods inherited from class com.adaptris.core.runtime.ChildRuntimeInfoComponentImpl

createObjectName, getParentId, getParentObjectName, registerMBean, unregisterMBean

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.adaptris.core.runtime.ChildRuntimeInfoComponentMBean

getParentId, getParentObjectName

Methods inherited from interface com.adaptris.core.runtime.BaseComponentMBean

createObjectName, registerMBean, unregisterMBean

Method Detail

getType

protected java.lang.String getType()

Specified by:

getType in class ChildRuntimeInfoComponentImpl

uniqueId

protected java.lang.String uniqueId()

Specified by:

uniqueId in class ChildRuntimeInfoComponentImpl

getParentRuntimeInfoComponent

public RuntimeInfoComponent getParentRuntimeInfoComponent()

Specified by:

getParentRuntimeInfoComponent in interface ChildRuntimeInfoComponent

retryMessage

public boolean retryMessage(SerializableMessage msg)
                     throws CoreException

Description copied from interface: DefaultFailedMessageRetrierJmxMBean

Retry a message.

Using metadata that is already present in the message, namely Workflow.WORKFLOW_ID_KEY, retry the message. Note that the return code only indicates that a workflow was found, and the message was successfully submitted to the workflow. It does not indicate anything about the successful processing (or not) of the message.

Specified by:

retryMessage in interface DefaultFailedMessageRetrierJmxMBean

Parameters:

msg - the message

Returns:

true if the message was successfully submitted to a workflow, false otherwise.

Throws:

CoreException - if there was an error unwrapping the file using DefaultSerializableMessageTranslator

retryMessage

public boolean retryMessage(java.io.File file)
                     throws java.io.IOException,
                            CoreException

Description copied from interface: DefaultFailedMessageRetrierJmxMBean

Retry a message that has been written to the filesystem.

This assumes that the contents of the file has previously been encoded using a MimeEncoder and written out to the filesystem. It will decode the file and then submit it using DefaultFailedMessageRetrierJmxMBean.retryMessage(SerializableMessage). Note that the return code only indicates that a workflow was found, and the message was successfully submitted to the workflow. It does not indicate anything about the successful processing (or not) of the message.

Specified by:

retryMessage in interface DefaultFailedMessageRetrierJmxMBean

Parameters:

file - the file, local to the adapter that contains the message to be retried.

Returns:

true if the message was successfully submitted to a workflow, false otherwise.

Throws:

java.io.IOException - if there was an error reading the file.

CoreException - if there was an error decoding the file using MimeEncoder.