C
- Type of processing contextpublic abstract class TerminateOnErrorProcessingStage<C extends ProcessingContext> extends RoutingProcessingStage<C>
Constructor and Description |
---|
TerminateOnErrorProcessingStage(ProcessingStage<C> next) |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
doExecute(C context)
Perform processing.
|
protected ProcessingStage<C> |
doExecute(C context,
ProcessingStage<C> next)
Execute current stage and calculate the next stage.
|
execute
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
after
public TerminateOnErrorProcessingStage(ProcessingStage<C> next)
protected final ProcessingStage<C> doExecute(C context, ProcessingStage<C> next)
RoutingProcessingStage
doExecute
in class RoutingProcessingStage<C extends ProcessingContext>
context
- Processing contextnext
- Default next stage (usually statically configured in ProcessorFactory)protected abstract void doExecute(C context) throws InterruptedException
InterruptedException
Copyright © 2016–2021. All rights reserved.