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

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
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
 
Constructor Summary
MessageAwareListener(ListenerManager controller, ConfigTree config)
          public constructor
 
Method Summary
protected  void checkMyParms()
          Check for mandatory and optional attributes in parameter tree
 boolean finalizeRun()
           
 boolean initializeRun()
           
 boolean isMessageAware()
           
 void waitForEventAndProcess(long maxWaitMillis)
           
 
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

_pickUpCourier

protected org.jboss.internal.soa.esb.couriers.PickUpOnlyCourier _pickUpCourier
Constructor Detail

MessageAwareListener

public MessageAwareListener(ListenerManager controller,
                            ConfigTree config)
                     throws ConfigurationException
public constructor

Parameters:
controller - ListenerManager - the controlling process
config - ConfigTree - Containing 'static' configuration for this instance
Throws:
java.lang.Exception
ConfigurationException
Method Detail

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