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)
