org.jboss.soa.esb.listeners.message
Class MessageAwareListener
java.lang.Object
java.util.Observable
org.jboss.soa.esb.listeners.AbstractManagedListener
org.jboss.soa.esb.listeners.message.MessageAwareListener
- All Implemented Interfaces:
- java.lang.Runnable, java.util.Observer
- Direct Known Subclasses:
- CbrListener
public class MessageAwareListener
- extends AbstractManagedListener
Esb Message aware transport independent listener.
Relies on the CourierFactory to obtain an appropriate Courier
for the EPR this listener will be listening on
Keeps a thread pool to instantiate ActionProcessingPipelines whenever a Message is received
- Since:
- Version 4.0
- Author:
- schifest@heuristica.com.ar
|
Field Summary |
protected org.jboss.internal.soa.esb.couriers.PickUpOnlyCourier |
_pickUpCourier
|
| Fields inherited from class org.jboss.soa.esb.listeners.AbstractManagedListener |
_bRegistered, _config, _controller, _defaultMaxThreads, _epr, _eprCategoryName, _eprName, _execService, _logger, _maxThreads, _pauseLapseInMillis |
| 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 |
_pickUpCourier
protected org.jboss.internal.soa.esb.couriers.PickUpOnlyCourier _pickUpCourier
MessageAwareListener
public MessageAwareListener(ListenerManager controller,
ConfigTree config)
throws ConfigurationException
- public constructor
- Parameters:
controller - ListenerManager - the controlling processconfig - ConfigTree - Containing 'static' configuration for this instance
- Throws:
java.lang.Exception
ConfigurationException
checkMyParms
protected void checkMyParms()
throws ConfigurationException
- Check for mandatory and optional attributes in parameter tree
- Overrides:
checkMyParms in class AbstractManagedListener
- Throws:
ConfigurationException - -
if mandatory atts are not right or actionClass not in
classpath
isMessageAware
public boolean isMessageAware()
- Specified by:
isMessageAware in class AbstractManagedListener
initializeRun
public boolean initializeRun()
- Specified by:
initializeRun in class AbstractManagedListener
finalizeRun
public boolean finalizeRun()
- Specified by:
finalizeRun in class AbstractManagedListener
waitForEventAndProcess
public void waitForEventAndProcess(long maxWaitMillis)
- Specified by:
waitForEventAndProcess in class AbstractManagedListener