org.jboss.soa.esb.listeners.gateway
Class JmsGatewayListener

java.lang.Object
  extended by org.jboss.soa.esb.listeners.gateway.JmsGatewayListener
All Implemented Interfaces:
java.lang.Runnable

public class JmsGatewayListener
extends java.lang.Object
implements java.lang.Runnable


Field Summary
protected  java.lang.Object _composer
           
protected  java.lang.Class _composerClass
           
protected  java.lang.String _composerName
           
protected  ConfigTree _config
           
protected  GatewayListenerController _controller
           
protected  Courier _courier
           
protected static org.apache.log4j.Logger _logger
           
protected  javax.jms.MessageConsumer _messageReceiver
           
protected  java.lang.String _messageSelector
           
protected  EPR _myEpr
           
protected  java.lang.reflect.Method _processMethod
           
protected  javax.jms.Queue _queue
           
protected  javax.jms.QueueConnection _queueConnection
           
protected  java.lang.String _queueName
           
protected  javax.jms.QueueSession _queueSession
           
protected  java.lang.String _serviceCategory
           
protected  java.lang.String _serviceName
           
protected  long _sleepForRetries
           
protected  java.util.Collection<EPR> _targetEprs
           
protected  java.lang.String _targetServiceCategory
           
protected  java.lang.String _targetServiceName
           
 
Constructor Summary
JmsGatewayListener(GatewayListenerController commandListener, ConfigTree listenerConfig)
           
 
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
 

Field Detail

_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
Constructor Detail

JmsGatewayListener

public JmsGatewayListener(GatewayListenerController commandListener,
                          ConfigTree listenerConfig)
                   throws java.lang.Exception
Throws:
java.lang.Exception
Method Detail

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