org.jboss.soa.esb.listeners.message
Class CbrListener
java.lang.Object
java.util.Observable
org.jboss.soa.esb.listeners.AbstractManagedListener
org.jboss.soa.esb.listeners.message.MessageAwareListener
org.jboss.soa.esb.listeners.message.CbrListener
- All Implemented Interfaces:
- java.lang.Runnable, java.util.Observer
public class CbrListener
- extends MessageAwareListener
Esb Message aware Content Based Router listener.
- Since:
- Version 4.0
- Author:
- Kurt Stam
| 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 |
_logger
protected static transient org.apache.log4j.Logger _logger
_cbr
protected ContentBasedRouter _cbr
_ruleSet
protected java.lang.String _ruleSet
_ruleLanguage
protected java.lang.String _ruleLanguage
_ruleReload
protected boolean _ruleReload
CbrListener
public CbrListener(ListenerManager controller,
ConfigTree config)
throws ConfigurationException
- Throws:
ConfigurationException
checkMyParms
protected void checkMyParms()
throws ConfigurationException
- Description copied from class:
MessageAwareListener
- Check for mandatory and optional attributes in parameter tree
- Overrides:
checkMyParms in class MessageAwareListener
- Throws:
ConfigurationException - -
if mandatory atts are not right or actionClass not in
classpath
initializeRun
public boolean initializeRun()
- Overrides:
initializeRun in class MessageAwareListener
waitForEventAndProcess
public void waitForEventAndProcess(long maxWaitMillis)
- Overrides:
waitForEventAndProcess in class MessageAwareListener