[jboss-svn-commits] JBL Code SVN: r7387 - labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message

[jboss-svn-commits at lists.jboss.org]

Author: estebanschifman
Date: 2006-11-03 16:07:31 -0500 (Fri, 03 Nov 2006)
New Revision: 7387

Modified:
   labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/JmsQueueListener.java
Log:
Put some method local variables as instance variables so derived classes will see them

Modified: labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/JmsQueueListener.java
===================================================================
--- labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/JmsQueueListener.java	2006-11-03 20:41:38 UTC (rev 7386)
+++ labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/JmsQueueListener.java	2006-11-03 21:07:31 UTC (rev 7387)
@@ -120,7 +120,7 @@
     protected void checkMyParms() throws ConfigurationException 
     {
         // Default value of obtainAttribute is null - Exception will be thrown
-        String sQueue	= obtainAttribute(JMSEpr.DESTINATION_NAME_TAG, null);
+        _queueName		= obtainAttribute(JMSEpr.DESTINATION_NAME_TAG, null);
 
         _eprCategoryName= obtainAttribute(ListenerTagNames.SERVICE_CATEGORY_NAME_TAG,null);
         _eprName		= obtainAttribute(ListenerTagNames.SERVICE_NAME_TAG,null);
@@ -132,22 +132,22 @@
         _oQsess = null;
         _oQueue = null;
 
-        String sJndiType = obtainAttribute	(JMSEpr.JNDI_TYPE_TAG	,"jboss");
-        String sJndiURL = obtainAttribute	(JMSEpr.JNDI_URL_TAG	,"localhost");
-        Context oJndiCtx = AppServerContext.getServerContext(sJndiType,sJndiURL);
+        _jndiType = obtainAttribute	(JMSEpr.JNDI_TYPE_TAG	,"jboss");
+        _jndiURL = obtainAttribute	(JMSEpr.JNDI_URL_TAG	,"localhost");
+        _jndiCtx = AppServerContext.getServerContext(_jndiType,_jndiURL);
 
-        String sFactClass = obtainAttribute(JMSEpr.CONNECTION_FACTORY_TAG, "ConnectionFactory");
-        _epr = new JMSEpr(JMSEpr.QUEUE_TYPE,sQueue,sFactClass
-        				,sJndiType,sJndiURL,_sSelector);
+        _jmsFactoryClass = obtainAttribute(JMSEpr.CONNECTION_FACTORY_TAG, "ConnectionFactory");
+        _epr = new JMSEpr(JMSEpr.QUEUE_TYPE,_queueName,_jmsFactoryClass
+        				,_jndiType,_jndiURL,_sSelector);
 
 		Exception thrown = null;
         try
         {
-        	Object tmp = oJndiCtx.lookup(sFactClass);
+        	Object tmp = _jndiCtx.lookup(_jmsFactoryClass);
         	QueueConnectionFactory qcf = (QueueConnectionFactory) tmp;
 
         	_oQconn = qcf.createQueueConnection();
-        	_oQueue = (Queue) oJndiCtx.lookup(sQueue);
+        	_oQueue = (Queue) _jndiCtx.lookup(_queueName);
         	_oQsess = _oQconn.createQueueSession(false,TopicSession.AUTO_ACKNOWLEDGE);
         	_oQconn.start();
         	_receiver = _oQsess.createReceiver(_oQueue, _sSelector);
@@ -248,7 +248,13 @@
     protected QueueConnection	_oQconn;
     protected QueueSession		_oQsess;
     protected Queue 			_oQueue;
-    protected String 			_sSelector;
+    protected String	_queueName
+    					,_sSelector
+    					,_jndiType
+    					,_jndiURL
+    					,_jmsFactoryClass
+    ;
+    protected Context			_jndiCtx;
     protected int				_iSleepForRetry;
 
     protected static transient Logger _logger = Logger.getLogger(JmsQueueListener.class);