org.jboss.soa.esb.listeners.old
Class AbstractPassiveListener

java.lang.Object
  extended by org.jboss.soa.esb.listeners.old.AbstractListener
      extended by org.jboss.soa.esb.listeners.old.AbstractPassiveListener
All Implemented Interfaces:
java.lang.Runnable
Direct Known Subclasses:
HttpListener

public abstract class AbstractPassiveListener
extends AbstractListener

Base class to be implmented by listener implementations which use a channel implementation doing the listening stuff like periodically receiving on a queue.

Author:
Johan Kumps

Nested Class Summary
 
Nested classes/interfaces inherited from class org.jboss.soa.esb.listeners.old.AbstractListener
AbstractListener.ActionProcessingPipeline
 
Field Summary
 
Fields inherited from class org.jboss.soa.esb.listeners.old.AbstractListener
listenerConfig, logger, m_iMaxThr, m_iQthr, m_iSleepForThreads, m_iUpperThreadLimit, m_oActionDefinitionFactory, m_oActions, m_oDad, m_oMsgFactory, m_oThrGrp, MESSAGE_PROCESSING_ACTIONS_LIST
 
Constructor Summary
protected AbstractPassiveListener(GpListener p_oDad, ConfigTree p_oParms, ActionDefinitionFactory actionDefinitionFactory)
           
 
Method Summary
protected  java.lang.Object[] receive()
          Receive message from underlying channel implementation.
 
Methods inherited from class org.jboss.soa.esb.listeners.old.AbstractListener
close, processingComplete, processingError, run
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

AbstractPassiveListener

protected AbstractPassiveListener(GpListener p_oDad,
                                  ConfigTree p_oParms,
                                  ActionDefinitionFactory actionDefinitionFactory)
                           throws java.lang.Exception
Throws:
java.lang.Exception
Method Detail

receive

protected java.lang.Object[] receive()
Description copied from class: AbstractListener
Receive message from underlying channel implementation.

Implementations must perform a blocking receive.

Specified by:
receive in class AbstractListener
Returns:
An array of Objects received on the channel.