org.jboss.soa.esb.listeners.old
Class JmsQueueListener
java.lang.Object
org.jboss.soa.esb.listeners.old.AbstractListener
org.jboss.soa.esb.listeners.old.JmsQueueListener
- All Implemented Interfaces:
- java.lang.Runnable
public class JmsQueueListener
- extends AbstractListener
| 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 |
|
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 java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
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
JmsQueueListener
public JmsQueueListener(GpListener commandListener,
ConfigTree listenerConfig,
ActionDefinitionFactory actionDefinitionFactory)
throws java.lang.Exception
- Throws:
java.lang.Exception
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.