@ComponentProfile(summary="Basic Single Threaded Workflow", tag="workflow,base") public class StandardWorkflow extends StandardWorkflowImpl
Standard implementation of Workflow
. Links specific destinations in a Channel
. Consumes
AdaptrisMessage
s from a single ConsumeDestination
, processes these messages using a
ServiceCollection
, then produces the processed message using a AdaptrisMessageProducer
. In the event of
an Exception
processing a message, passes the problem message to a configured AdaptrisMessageListener
.
In the adapter configuration file this class is aliased as standard-workflow which is the preferred alternative to the fully qualified classname when building your configuration.
eventHandler, log, startTime, stopTime
PREVIOUS_GUID_KEY, WORKFLOW_ID_KEY
Constructor and Description |
---|
StandardWorkflow() |
StandardWorkflow(AdaptrisMessageConsumer consumer,
AdaptrisMessageProducer producer) |
StandardWorkflow(AdaptrisMessageConsumer consumer,
ServiceCollection services,
AdaptrisMessageProducer producer) |
Modifier and Type | Method and Description |
---|---|
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.
|
closeWorkflow, handleMessage, initialiseWorkflow, prepareWorkflow, resubmitMessage, startWorkflow, stopWorkflow
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
public StandardWorkflow()
public StandardWorkflow(AdaptrisMessageConsumer consumer, AdaptrisMessageProducer producer)
public StandardWorkflow(AdaptrisMessageConsumer consumer, ServiceCollection services, AdaptrisMessageProducer producer)
public void onAdaptrisMessage(AdaptrisMessage msg, java.util.function.Consumer<AdaptrisMessage> success, java.util.function.Consumer<AdaptrisMessage> failure)
AdaptrisMessageListener
onAdaptrisMessage
in interface AdaptrisMessageListener
onAdaptrisMessage
in class StandardWorkflowImpl
msg
- the messagesuccess
- called on successfailure
- called on failure