public abstract class StandardWorkflowImpl extends WorkflowImp
eventHandler, log, startTime, stopTime
PREVIOUS_GUID_KEY, WORKFLOW_ID_KEY
Constructor and Description |
---|
StandardWorkflowImpl() |
Modifier and Type | Method and Description |
---|---|
protected void |
closeWorkflow()
Close the workflow.
|
protected void |
handleMessage(AdaptrisMessage msg,
boolean clone) |
protected void |
initialiseWorkflow()
Initialise the workflow.
|
void |
onAdaptrisMessage(AdaptrisMessage msg,
java.util.function.Consumer<AdaptrisMessage> success,
java.util.function.Consumer<AdaptrisMessage> failure)
Handle a message with call back actions if a message is successful or failed.
|
protected void |
prepareWorkflow() |
protected void |
resubmitMessage(AdaptrisMessage msg)
Resubmit a message upon the channel becoming available again.
|
protected void |
startWorkflow()
Start the workflow.
|
protected void |
stopWorkflow()
Stop the workflow.
|
addConsumeLocation, addInterceptor, changeState, channelUnavailableWait, close, copyExceptionHeaders, disableMessageCount, doProduce, friendlyName, getChannelUnavailableWaitInterval, getComments, getConsumer, getDisableDefaultMessageCount, getInterceptors, getMessageErrorHandler, getMessageLogger, getProduceExceptionHandler, getProducer, getSendEvents, getServiceCollection, getUniqueId, handleBadMessage, handleBadMessage, handleChannelUnavailable, handleProduceException, init, lastStartTime, lastStopTime, logSuccess, messageLogger, obtainChannel, obtainWorkflowId, prepare, processingStart, registerActiveMsgErrorHandler, registerChannel, registerEventHandler, requestClose, requestInit, requestStart, requestStop, retrieveActiveMsgErrorHandler, retrieveComponentState, sendEvents, sendMessageLifecycleEvent, setChannelUnavailableWaitInterval, setComments, setConsumer, setDisableDefaultMessageCount, setInterceptors, setMessageErrorHandler, setMessageLogger, setProduceExceptionHandler, setProducer, setSendEvents, setServiceCollection, setUniqueId, start, stop, workflowEnd, workflowStart
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
onAdaptrisMessage, onAdaptrisMessage
protected void initialiseWorkflow() throws CoreException
WorkflowImp
initialiseWorkflow
in class WorkflowImp
CoreException
- encapsulating any underlying ExceptionWorkflowImp.initialiseWorkflow()
protected void startWorkflow() throws CoreException
WorkflowImp
startWorkflow
in class WorkflowImp
CoreException
- encapsulating any underlying ExceptionWorkflowImp.startWorkflow()
protected void stopWorkflow()
WorkflowImp
stopWorkflow
in class WorkflowImp
WorkflowImp.stopWorkflow()
protected void closeWorkflow()
WorkflowImp
closeWorkflow
in class WorkflowImp
WorkflowImp.closeWorkflow()
protected void prepareWorkflow() throws CoreException
prepareWorkflow
in class WorkflowImp
CoreException
public void onAdaptrisMessage(AdaptrisMessage msg, java.util.function.Consumer<AdaptrisMessage> success, java.util.function.Consumer<AdaptrisMessage> failure)
AdaptrisMessageListener
msg
- the messagesuccess
- called on successfailure
- called on failureprotected void resubmitMessage(AdaptrisMessage msg)
WorkflowImp
resubmitMessage
in class WorkflowImp
msg
- the AdaptrisMessage.WorkflowImp.resubmitMessage(com.adaptris.core.AdaptrisMessage)
protected void handleMessage(AdaptrisMessage msg, boolean clone)