public abstract class FailedMessageRetrierImp extends java.lang.Object implements FailedMessageRetrier
Component which consumes AdaptrisMessage
s and, based on message metadata, resubmits them to the
Workflow
which processed them originally.
Modifier and Type | Field and Description |
---|---|
protected org.slf4j.Logger |
log |
Constructor and Description |
---|
FailedMessageRetrierImp()
Creates a new instance.
|
Modifier and Type | Method and Description |
---|---|
void |
addWorkflow(Workflow workflow)
Add a Workflow to the internal register of workflows
|
void |
clearWorkflows()
Clear the internal store of workflows.
|
java.lang.String |
getUniqueId()
Get the unique-id that is associated with this component.
|
protected Workflow |
getWorkflow(AdaptrisMessage msg) |
protected Workflow |
getWorkflow(java.lang.String workflowId) |
protected java.util.Map<java.lang.String,Workflow> |
getWorkflows() |
java.util.Collection<java.lang.String> |
registeredWorkflowIds()
Return the list of workflow-ids registered.
|
void |
setUniqueId(java.lang.String uniqueId) |
protected void |
updateRetryCountMetadata(AdaptrisMessage msg) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close, init, start, stop
prepare
public FailedMessageRetrierImp()
Creates a new instance. Defaults to new empty StandaloneConsumer
, which will do nothing.
protected Workflow getWorkflow(AdaptrisMessage msg) throws CoreException
CoreException
protected Workflow getWorkflow(java.lang.String workflowId) throws CoreException
CoreException
protected void updateRetryCountMetadata(AdaptrisMessage msg)
public void addWorkflow(Workflow workflow) throws CoreException
FailedMessageRetrier
Add a Workflow to the internal store. If the generated key is not unique aCoreException is thrown.
addWorkflow
in interface FailedMessageRetrier
workflow
- the workflow to addCoreException
- if it is considered a duplicatepublic void clearWorkflows()
FailedMessageRetrier
clearWorkflows
in interface FailedMessageRetrier
public java.util.Collection<java.lang.String> registeredWorkflowIds()
FailedMessageRetrier
registeredWorkflowIds
in interface FailedMessageRetrier
protected java.util.Map<java.lang.String,Workflow> getWorkflows()
public java.lang.String getUniqueId()
AdaptrisComponent
getUniqueId
in interface AdaptrisComponent
public void setUniqueId(java.lang.String uniqueId)