org.jboss.soa.esb.listeners.message
Class CbrListener

java.lang.Object
  extended by java.util.Observable
      extended by org.jboss.soa.esb.listeners.AbstractManagedListener
          extended by org.jboss.soa.esb.listeners.message.MessageAwareListener
              extended by 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

Field Summary
protected  ContentBasedRouter _cbr
           
protected static org.apache.log4j.Logger _logger
           
protected  java.lang.String _ruleLanguage
           
protected  boolean _ruleReload
           
protected  java.lang.String _ruleSet
           
 
Fields inherited from class org.jboss.soa.esb.listeners.message.MessageAwareListener
_pickUpCourier
 
Fields inherited from class org.jboss.soa.esb.listeners.AbstractManagedListener
_bRegistered, _config, _controller, _defaultMaxThreads, _epr, _eprCategoryName, _eprName, _execService, _maxThreads, _pauseLapseInMillis
 
Constructor Summary
CbrListener(ListenerManager controller, ConfigTree config)
           
 
Method Summary
protected  void checkMyParms()
          Check for mandatory and optional attributes in parameter tree
 boolean initializeRun()
           
 void waitForEventAndProcess(long maxWaitMillis)
           
 
Methods inherited from class org.jboss.soa.esb.listeners.message.MessageAwareListener
finalizeRun, isMessageAware
 
Methods inherited from class org.jboss.soa.esb.listeners.AbstractManagedListener
hasActiveTreads, obtainAttribute, registerProcess, resetThreadCount, run, unregisterProcess, update, updateThreadCount, waitUntilReady
 
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

_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
Constructor Detail

CbrListener

public CbrListener(ListenerManager controller,
                   ConfigTree config)
            throws ConfigurationException
Throws:
ConfigurationException
Method Detail

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