@DispatchLayerErrorReaction(emits=JOB, relaysUnmodified=true, stateEffects={UPDATE_LOCAL_STATE,REMOVE_LOCAL_STATE}) @DispatchLayerJobReaction(emits={}, relaysUnmodified=true, stateEffects=CREATE_LOCAL_STATE) @DispatchLayerResultReaction(emits={}, relaysUnmodified=true, stateEffects=REMOVE_LOCAL_STATE) public class Failover extends AbstractErrorHandlerLayer<com.fasterxml.jackson.databind.JsonNode>
AbstractErrorHandlerLayer.JobState
Modifier and Type | Field and Description |
---|---|
static String |
URI |
CLEANUP_DELAY_MS, cleanupTimer, dispatchStack
Constructor and Description |
---|
Failover() |
Modifier and Type | Method and Description |
---|---|
void |
configure(com.fasterxml.jackson.databind.JsonNode config)
When the item is built from the workflow definition XML the object is
first constructed with a default constructor then this method is called,
passing in the configuration bean returned by getConfiguration().
|
com.fasterxml.jackson.databind.JsonNode |
getConfiguration()
Each item stores configuration within a bean of type ConfigurationType,
this method returns the configuration.
|
protected AbstractErrorHandlerLayer.JobState |
getStateObject(DispatchJobEvent jobEvent)
Generate an appropriate state object from the specified job event.
|
void |
receiveJob(DispatchJobEvent jobEvent)
Receive a job from the layer above, store it in the state map then relay
it to the layer below with a modified activity list containing only the
activity at index 0
|
addJobToStateList, finishedWith, forget, getJobsCopy, getJobsDefault, receiveError, receiveResult, receiveResultCompletion, removeJob
getAbove, getBelow, getProcessor, receiveJobQueue, setDispatchStack
public static final String URI
protected AbstractErrorHandlerLayer.JobState getStateObject(DispatchJobEvent jobEvent)
AbstractErrorHandlerLayer
getStateObject
in class AbstractErrorHandlerLayer<com.fasterxml.jackson.databind.JsonNode>
public void receiveJob(DispatchJobEvent jobEvent)
receiveJob
in interface DispatchLayer<com.fasterxml.jackson.databind.JsonNode>
receiveJob
in class AbstractErrorHandlerLayer<com.fasterxml.jackson.databind.JsonNode>
public void configure(com.fasterxml.jackson.databind.JsonNode config)
Configurable
public com.fasterxml.jackson.databind.JsonNode getConfiguration()
Configurable
Copyright © 2015–2016 The Apache Software Foundation. All rights reserved.