com.vordel.circuit

Class CircuitChainProcessor

java.lang.Object

com.vordel.circuit.FilterContainer

com.vordel.circuit.MessageProcessor

com.vordel.circuit.DelegatingProcessor

com.vordel.circuit.CircuitChainProcessor

Direct Known Subclasses:

SyntheticCircuitChainProcessor

public class CircuitChainProcessor
extends DelegatingProcessor

Field Summary

Fields

Modifier and Type	Field and Description
protected CircuitDelegateFilter	cdf
protected java.util.Map<java.lang.String,CircuitDelegateProcessor>	cdps

Fields inherited from class com.vordel.circuit.MessageProcessor

logMask, logMaskType

Constructor Summary

Constructors

Constructor and Description
CircuitChainProcessor()

Method Summary

Methods

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

Methods inherited from class com.vordel.circuit.DelegatingProcessor

callCircuit, callCircuit, getCDProc, getCDProc

Methods inherited from class com.vordel.circuit.MessageProcessor

filterDetached, getCategory, getFilterMessage, getLogMask, logFailure, logFatal, logMessagePayload, logSuccess, report, report, toString

Methods inherited from class com.vordel.circuit.FilterContainer

configureFilter, createFilterContainer, getFilter, setFilter

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

cdf

protected CircuitDelegateFilter cdf

cdps

protected java.util.Map<java.lang.String,CircuitDelegateProcessor> cdps

Constructor Detail

CircuitChainProcessor

public CircuitChainProcessor()

Method Detail

filterAttached

public void filterAttached(com.vordel.precipitate.SolutionPack ctx,
                  Entity entity)
                    throws EntityStoreException

Description copied from class: FilterContainer

Called on a filter's container when the filter is configured. Any domain-specific initialisation of the filter container can be done at this point. This will be called at least once when the filter attaches.

Overrides:

filterAttached in class MessageProcessor

Parameters:

ctx - configuration context for the filter attached to this container.

Throws:

EntityStoreException

attach

public void attach(com.vordel.precipitate.SolutionPack ctx,
          CircuitChainFilter filter,
          CircuitCache circuitCache)
            throws EntityStoreException

Throws:

EntityStoreException

invoke

public boolean invoke(Circuit c,
             Message m)
               throws CircuitAbortException

Description copied from class: MessageProcessor

invoked by circuit to act on a message

Specified by:

invoke in class MessageProcessor

Parameters:

c - The Circuit context

m - The message

Returns:

predicate indicating success of filter execution

Throws:

CircuitAbortException

addCircuitProcessor

protected void addCircuitProcessor(com.vordel.precipitate.SolutionPack ctx,
                       CircuitReference cr)
                            throws EntityStoreException

Throws:

EntityStoreException

callCircuit

protected boolean callCircuit(Circuit ci,
                  CircuitReference cr,
                  Message m)
                       throws CircuitAbortException

Throws:

CircuitAbortException