|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||
java.lang.Objectorg.jboss.soa.esb.listeners.message.AbstractListener
org.jboss.soa.esb.listeners.message.JmsQueueListener
public class JmsQueueListener
Esb Message aware JMS queue listener.
Expects an Object message whose getObject() method returns an org.jboss.soa.esb.message.Message
| Field Summary | |
|---|---|
protected boolean |
_bError
|
protected JMSEpr |
_epr
|
protected java.lang.String |
_eprCategoryName
|
protected java.lang.String |
_eprName
|
protected int |
_iSleepForRetry
|
protected java.lang.String |
_jmsFactoryClass
|
protected javax.naming.Context |
_jndiCtx
|
protected java.lang.String |
_jndiType
|
protected java.lang.String |
_jndiURL
|
protected static org.apache.log4j.Logger |
_logger
|
protected javax.jms.QueueConnection |
_oQconn
|
protected javax.jms.QueueSession |
_oQsess
|
protected javax.jms.Queue |
_oQueue
|
protected java.lang.String |
_queueName
|
protected javax.jms.MessageConsumer |
_receiver
|
protected java.lang.String |
_sSelector
|
| Fields inherited from class org.jboss.soa.esb.listeners.message.AbstractListener |
|---|
_config, _controller, logger, m_iMaxThr, m_iUpperThreadLimit, PARM_MAX_THREADS, pipelineExecutorPool |
| Constructor Summary | |
|---|---|
JmsQueueListener(EsbListenerController controller,
ConfigTree config)
public constructor |
|
| Method Summary | |
|---|---|
protected void |
checkMyParms()
Check for mandatory and optional attributes in parameter tree |
protected void |
cleanup()
|
protected java.lang.String |
obtainAttribute(java.lang.String p_sAtt,
java.lang.String p_sDefault)
|
protected Message |
receiveEsbMessage(long millis)
|
void |
run()
Loops until controlling process determines Waits for JMS Object messages containing ESB messages When one is received, instantiates an action processing pipeline to process it Pipeline is started in new Thread |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Field Detail |
|---|
protected java.lang.String _eprCategoryName
protected java.lang.String _eprName
protected JMSEpr _epr
protected javax.jms.MessageConsumer _receiver
protected boolean _bError
protected javax.jms.QueueConnection _oQconn
protected javax.jms.QueueSession _oQsess
protected javax.jms.Queue _oQueue
protected java.lang.String _queueName
protected java.lang.String _sSelector
protected java.lang.String _jndiType
protected java.lang.String _jndiURL
protected java.lang.String _jmsFactoryClass
protected javax.naming.Context _jndiCtx
protected int _iSleepForRetry
protected static transient org.apache.log4j.Logger _logger
| Constructor Detail |
|---|
public JmsQueueListener(EsbListenerController controller,
ConfigTree config)
throws ConfigurationException
controller - EsbListenerController - the controlling processconfig - ConfigTree - Containing 'static' configuration for this instance
java.lang.Exception
ConfigurationException| Method Detail |
|---|
public void run()
protected void checkMyParms()
throws ConfigurationException
java.lang.Exception - -
if mandatory atts are not right or actionClass not in
classpath
ConfigurationExceptionprotected Message receiveEsbMessage(long millis)
protected void cleanup()
protected java.lang.String obtainAttribute(java.lang.String p_sAtt,
java.lang.String p_sDefault)
throws ConfigurationException
ConfigurationException
|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||