svn commit: r940345 - /jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/sampler/JMSSampler.java

[se...@apache.org]

Author: sebb
Date: Mon May  3 01:31:50 2010
New Revision: 940345

URL: http://svn.apache.org/viewvc?rev=940345&view=rev
Log:
sendQueue does not need to be an instance variable

Modified:
    jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/sampler/JMSSampler.java

Modified: jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/sampler/JMSSampler.java
URL: http://svn.apache.org/viewvc/jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/sampler/JMSSampler.java?rev=940345&r1=940344&r2=940345&view=diff
==============================================================================
--- jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/sampler/JMSSampler.java (original)
+++ jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/sampler/JMSSampler.java Mon May  3 01:31:50 2010
@@ -98,8 +98,6 @@ public class JMSSampler extends Abstract
     //
     // Member variables
     //
-    /** Factory for the connections to the queueing system. */
-    // NOTUSED private QueueConnectionFactory factory;
     /** Queue for receiving messages (if applicable). */
     private transient Queue receiveQueue;
 
@@ -109,11 +107,6 @@ public class JMSSampler extends Abstract
     /** Connection to the queueing system. */
     private transient QueueConnection connection;
 
-    /** Queue for sending messages. */
-    private transient Queue sendQueue;
-
-    /** Is the communication oneway? */
-    // NOTUSED private boolean oneway;
     /** The executor for (pseudo) synchronous communication. */
     private transient QueueExecutor executor;
 
@@ -307,9 +300,8 @@ public class JMSSampler extends Abstract
                 throw new IllegalStateException(msg);
             }
             QueueConnectionFactory factory = (QueueConnectionFactory) obj;
-            Queue queue = (Queue) context.lookup(getSendQueue());
+            Queue sendQueue = (Queue) context.lookup(getSendQueue());
 
-            sendQueue = queue;
             if (!useTemporyQueue()) {
                 receiveQueue = (Queue) context.lookup(getReceiveQueue());
                 receiverThread = Receiver.createReceiver(factory, receiveQueue, getPrincipal(context), getCredentials(context)