org.jboss.soa.esb.listeners.gateway
Class JmsGatewayListener
java.lang.Object
org.jboss.soa.esb.listeners.gateway.JmsGatewayListener
- All Implemented Interfaces:
- java.lang.Runnable
public class JmsGatewayListener
- extends java.lang.Object
- implements java.lang.Runnable
|
Method Summary |
protected void |
checkMyParms()
Check for mandatory and optional attributes in parameter tree |
protected javax.jms.Message |
receiveOne()
Receive one message and retry if connection |
protected void |
resolveComposerClass()
|
void |
run()
|
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
_logger
protected static final org.apache.log4j.Logger _logger
_queueName
protected java.lang.String _queueName
_queueConnection
protected javax.jms.QueueConnection _queueConnection
_queueSession
protected javax.jms.QueueSession _queueSession
_queue
protected javax.jms.Queue _queue
_messageReceiver
protected javax.jms.MessageConsumer _messageReceiver
_messageSelector
protected java.lang.String _messageSelector
_config
protected ConfigTree _config
_controller
protected GatewayListenerController _controller
_sleepForRetries
protected final long _sleepForRetries
_serviceCategory
protected java.lang.String _serviceCategory
_serviceName
protected java.lang.String _serviceName
_targetServiceCategory
protected java.lang.String _targetServiceCategory
_targetServiceName
protected java.lang.String _targetServiceName
_myEpr
protected EPR _myEpr
_targetEprs
protected java.util.Collection<EPR> _targetEprs
_composerName
protected java.lang.String _composerName
_composerClass
protected java.lang.Class _composerClass
_composer
protected java.lang.Object _composer
_processMethod
protected java.lang.reflect.Method _processMethod
_courier
protected Courier _courier
JmsGatewayListener
public JmsGatewayListener(GatewayListenerController commandListener,
ConfigTree listenerConfig)
throws java.lang.Exception
- Throws:
java.lang.Exception
run
public void run()
- Specified by:
run in interface java.lang.Runnable
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
resolveComposerClass
protected void resolveComposerClass()
throws java.lang.Exception
- Throws:
java.lang.Exception
receiveOne
protected javax.jms.Message receiveOne()
- Receive one message and retry if connection
- Returns:
- javax.jms.Message - One input message, or null