@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 Retry extends AbstractErrorHandlerLayer<com.fasterxml.jackson.databind.JsonNode>
Default properties are as follows :
AbstractErrorHandlerLayer.JobState
Modifier and Type | Field and Description |
---|---|
static String |
URI |
CLEANUP_DELAY_MS, cleanupTimer, dispatchStack
Constructor and Description |
---|
Retry() |
Retry(int maxRetries,
int initialDelay,
int maxDelay,
double backoffFactor) |
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().
|
static com.fasterxml.jackson.databind.node.ObjectNode |
defaultConfig() |
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.
|
addJobToStateList, finishedWith, forget, getJobsCopy, getJobsDefault, receiveError, receiveJob, receiveResult, receiveResultCompletion, removeJob
getAbove, getBelow, getProcessor, receiveJobQueue, setDispatchStack
public static final String URI
public Retry()
public Retry(int maxRetries, int initialDelay, int maxDelay, double backoffFactor)
protected AbstractErrorHandlerLayer.JobState getStateObject(DispatchJobEvent jobEvent)
AbstractErrorHandlerLayer
getStateObject
in class AbstractErrorHandlerLayer<com.fasterxml.jackson.databind.JsonNode>
public void configure(com.fasterxml.jackson.databind.JsonNode config)
Configurable
public static com.fasterxml.jackson.databind.node.ObjectNode defaultConfig()
public com.fasterxml.jackson.databind.JsonNode getConfiguration()
Configurable
Copyright © 2015–2016 The Apache Software Foundation. All rights reserved.