You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@jakarta.apache.org by se...@apache.org on 2010/06/22 22:17:27 UTC
svn commit: r957011 - in
/jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms:
client/OnMessageSubscriber.java sampler/Receiver.java
Author: sebb
Date: Tue Jun 22 20:17:27 2010
New Revision: 957011
URL: http://svn.apache.org/viewvc?rev=957011&view=rev
Log:
Use MessageConsumer interface
Modified:
jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/client/OnMessageSubscriber.java
jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/sampler/Receiver.java
Modified: jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/client/OnMessageSubscriber.java
URL: http://svn.apache.org/viewvc/jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/client/OnMessageSubscriber.java?rev=957011&r1=957010&r2=957011&view=diff
==============================================================================
--- jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/client/OnMessageSubscriber.java (original)
+++ jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/client/OnMessageSubscriber.java Tue Jun 22 20:17:27 2010
@@ -21,11 +21,11 @@ package org.apache.jmeter.protocol.jms.c
import javax.naming.Context;
import javax.naming.NamingException;
import javax.jms.JMSException;
+import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import javax.jms.Topic;
import javax.jms.TopicConnection;
import javax.jms.TopicSession;
-import javax.jms.TopicSubscriber;
import org.apache.jmeter.protocol.jms.Utils;
import org.apache.jorphan.logging.LoggingManager;
@@ -50,7 +50,7 @@ public class OnMessageSubscriber {
private final Topic TOPIC;
- private final TopicSubscriber SUBSCRIBER;
+ private final MessageConsumer SUBSCRIBER;
/**
* Constructor takes the necessary JNDI related parameters to create a
Modified: jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/sampler/Receiver.java
URL: http://svn.apache.org/viewvc/jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/sampler/Receiver.java?rev=957011&r1=957010&r2=957011&view=diff
==============================================================================
--- jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/sampler/Receiver.java (original)
+++ jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/sampler/Receiver.java Tue Jun 22 20:17:27 2010
@@ -35,7 +35,7 @@ public class Receiver implements Runnabl
private final QueueSession session;
- private final QueueReceiver consumer;
+ private final MessageConsumer consumer;
private final QueueConnection conn;
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@jakarta.apache.org
For additional commands, e-mail: notifications-help@jakarta.apache.org