public class CircuitChainProcessor extends DelegatingProcessor
Modifier and Type | Field and Description |
---|---|
protected CircuitDelegateFilter |
cdf |
protected java.util.Map<java.lang.String,CircuitDelegateProcessor> |
cdps |
logMask, logMaskType
Constructor and Description |
---|
CircuitChainProcessor() |
Modifier and Type | Method and Description |
---|---|
protected void |
addCircuitProcessor(com.vordel.precipitate.SolutionPack ctx,
CircuitReference cr) |
void |
attach(com.vordel.precipitate.SolutionPack ctx,
CircuitChainFilter filter,
CircuitCache circuitCache) |
protected boolean |
callCircuit(Circuit ci,
CircuitReference cr,
Message m) |
void |
filterAttached(com.vordel.precipitate.SolutionPack ctx,
Entity entity)
Called on a filter's container when the filter is configured.
|
boolean |
invoke(Circuit c,
Message m)
invoked by circuit to act on a message
|
callCircuit, callCircuit, getCDProc, getCDProc
filterDetached, getCategory, getFilterMessage, getLogMask, logFailure, logFatal, logMessagePayload, logSuccess, report, report, toString
configureFilter, createFilterContainer, getFilter, setFilter
protected CircuitDelegateFilter cdf
protected java.util.Map<java.lang.String,CircuitDelegateProcessor> cdps
public void filterAttached(com.vordel.precipitate.SolutionPack ctx, Entity entity) throws EntityStoreException
FilterContainer
filterAttached
in class MessageProcessor
ctx
- configuration context for the filter attached to this
container.EntityStoreException
public void attach(com.vordel.precipitate.SolutionPack ctx, CircuitChainFilter filter, CircuitCache circuitCache) throws EntityStoreException
EntityStoreException
public boolean invoke(Circuit c, Message m) throws CircuitAbortException
MessageProcessor
invoke
in class MessageProcessor
c
- The Circuit contextm
- The messageCircuitAbortException
protected void addCircuitProcessor(com.vordel.precipitate.SolutionPack ctx, CircuitReference cr) throws EntityStoreException
EntityStoreException
protected boolean callCircuit(Circuit ci, CircuitReference cr, Message m) throws CircuitAbortException
CircuitAbortException
This documentation and all its contents and graphics, copyright © 1999 - 2011 Vordel