|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object java.util.Observable org.jboss.soa.esb.listeners.message.ActionProcessingPipeline
public class ActionProcessingPipeline
Action Processing Pipeline.
Runs a list of action classes on a message
Field Summary | |
---|---|
protected ConfigTree[] |
_actionList
|
protected ConfigTree |
_config
|
protected java.lang.String |
_currentAction
|
protected java.lang.Class |
_currentClass
|
protected int |
_currentIndex
|
protected java.lang.Object |
_currentProcessor
|
protected org.apache.log4j.Logger |
_logger
|
protected Message |
_message
|
Constructor Summary | |
---|---|
ActionProcessingPipeline(Message message,
ConfigTree config)
public constructor |
Method Summary | |
---|---|
protected void |
actionClassException(ConfigTree tree,
Message msg,
java.lang.Throwable thrown)
If 'current' action step was configured with a 'exceptionMethod' attribute that method will be called with a single argument of type Exception |
protected void |
actionClassFinishedOk(ConfigTree tree,
Message msg)
If 'current' action step was configured with an 'okMethod' attribute that method will be called with no arguments |
protected java.lang.String[] |
getActionNames()
|
Message |
getMessage()
|
boolean |
isProcessingComplete()
|
protected java.lang.String |
prematureTermination(java.lang.String s)
|
void |
run()
Implement Runnable Interface Uses reflection to instantiate action classes that must have a public constructor that takes a single ConfigTree as argument Requires each action class to have a public method that takes a Message and returns a Message Default name for it is 'process' but can optionally be defined in the 'process' attribute of the corresponding <action> element of the ConfigTree Each <action> element can optionally define a method (taking a Message argument) to be called upon successful completion of the action class (that step of the chain) Default name for it is 'process' but can optionally be defined in the 'process' attribute See actionClassException and actionClassFinishedOk |
void |
waitUntilComplete()
Wait until processing is complete. |
Methods inherited from class java.util.Observable |
---|
addObserver, clearChanged, countObservers, deleteObserver, deleteObservers, hasChanged, notifyObservers, notifyObservers, setChanged |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected ConfigTree[] _actionList
protected int _currentIndex
protected java.lang.String _currentAction
protected java.lang.Class _currentClass
protected java.lang.Object _currentProcessor
protected Message _message
protected ConfigTree _config
protected org.apache.log4j.Logger _logger
Constructor Detail |
---|
public ActionProcessingPipeline(Message message, ConfigTree config) throws ConfigurationException
message
- Message - The initial message to be run through the whole action
class chain
ConfigurationException
Method Detail |
---|
public Message getMessage()
public void run()
run
in interface java.lang.Runnable
protected java.lang.String prematureTermination(java.lang.String s)
protected void actionClassException(ConfigTree tree, Message msg, java.lang.Throwable thrown)
tree
- ConfigTree - where to look for the exceptionMetod attributethrown
- Exception - to be used in invocation to method (if found)protected void actionClassFinishedOk(ConfigTree tree, Message msg)
tree
- ConfigTree - where to look for the okMetod attributeprotected java.lang.String[] getActionNames()
public boolean isProcessingComplete()
public void waitUntilComplete()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |