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

java.lang.Object
  extended by org.jboss.soa.esb.listeners.old.AbstractListener
      extended by org.jboss.soa.esb.listeners.old.JmsQueueListener
All Implemented Interfaces:
java.lang.Runnable

public class JmsQueueListener
extends AbstractListener


Nested Class Summary
 
Nested classes/interfaces inherited from class org.jboss.soa.esb.listeners.old.AbstractListener
AbstractListener.ActionProcessingPipeline
 
Field Summary
protected  javax.jms.MessageConsumer jmsMessageReceiver
           
static java.lang.String LISTEN_JNDI_TYPE
           
static java.lang.String LISTEN_JNDI_URL
           
static java.lang.String LISTEN_MSG_SELECTOR
           
static java.lang.String LISTEN_QUEUE
           
static java.lang.String LISTEN_QUEUE_CONN_FACT
           
protected  boolean m_bError
           
protected  javax.jms.QueueConnection m_oQconn
           
protected  javax.jms.QueueSession m_oQsess
           
protected  javax.jms.Queue m_oQueue
           
protected  java.lang.String m_sSelector
           
 
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
JmsQueueListener(GpListener commandListener, ConfigTree listenerConfig, ActionDefinitionFactory actionDefinitionFactory)
           
 
Method Summary
protected  void checkMyParms()
          Check for mandatory and optional attributes in parameter tree
protected  void close()
          Close the listener implemenation.
protected  void processingComplete(java.lang.Object initialMessage)
          Called on the listener implementation when pipeline processing of a message is complete.
protected  void processingError(java.lang.Object initialMessage, ActionProcessor processor, java.lang.Throwable error)
          Called on the listener implementation when pipeline processing error has occured.
protected  java.lang.Object[] receive()
          Receive message from underlying channel implementation.
 
Methods inherited from class org.jboss.soa.esb.listeners.old.AbstractListener
run
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

LISTEN_QUEUE_CONN_FACT

public static final java.lang.String LISTEN_QUEUE_CONN_FACT
See Also:
Constant Field Values

LISTEN_JNDI_TYPE

public static final java.lang.String LISTEN_JNDI_TYPE
See Also:
Constant Field Values

LISTEN_JNDI_URL

public static final java.lang.String LISTEN_JNDI_URL
See Also:
Constant Field Values

LISTEN_QUEUE

public static final java.lang.String LISTEN_QUEUE
See Also:
Constant Field Values

LISTEN_MSG_SELECTOR

public static final java.lang.String LISTEN_MSG_SELECTOR
See Also:
Constant Field Values

m_bError

protected boolean m_bError

m_oQconn

protected javax.jms.QueueConnection m_oQconn

m_oQsess

protected javax.jms.QueueSession m_oQsess

m_oQueue

protected javax.jms.Queue m_oQueue

m_sSelector

protected java.lang.String m_sSelector

jmsMessageReceiver

protected javax.jms.MessageConsumer jmsMessageReceiver
Constructor Detail

JmsQueueListener

public JmsQueueListener(GpListener commandListener,
                        ConfigTree listenerConfig,
                        ActionDefinitionFactory actionDefinitionFactory)
                 throws java.lang.Exception
Throws:
java.lang.Exception
Method Detail

checkMyParms

protected void checkMyParms()
                     throws java.lang.Exception
Check for mandatory and optional attributes in parameter tree

Throws:
java.lang.Exception - - if mandatory atts are not right or actionClass not in classpath

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.

close

protected void close()
Description copied from class: AbstractListener
Close the listener implemenation.

Allows the listener to perform relevant close/cleanup tasks.

Specified by:
close in class AbstractListener

processingError

protected void processingError(java.lang.Object initialMessage,
                               ActionProcessor processor,
                               java.lang.Throwable error)
Description copied from class: AbstractListener
Called on the listener implementation when pipeline processing error has occured.

Specified by:
processingError in class AbstractListener
Parameters:
initialMessage - The message that was initialy supplied to the pipeline.
processor - The processor that raised the error. Can be null where the error was raised before pipeline processing of the message.
error - The error. Can be null.

processingComplete

protected void processingComplete(java.lang.Object initialMessage)
Description copied from class: AbstractListener
Called on the listener implementation when pipeline processing of a message is complete.

Specified by:
processingComplete in class AbstractListener
Parameters:
initialMessage - The message that was initialy supplied to the pipeline.