From ec2e89d1807d6dad9d678e2043c5f0e8c85d07c8 Mon Sep 17 00:00:00 2001
From: Rajith Muditha Attapattu <rajith@apache.org>
Date: Wed, 28 Nov 2007 19:47:26 +0000
Subject: Added the -DuseQueue option to switch between pub/sub and p2p. If
 useQueue is present then we use p2p.

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599117 13f79535-47bb-0310-9956-ffa450edef68
---
 .../src/main/java/org/apache/qpid/client/perf/MessageConsumerTest.java | 3 ++-
 .../src/main/java/org/apache/qpid/client/perf/MessageProducerTest.java | 3 ++-
 .../perftests/src/main/java/org/apache/qpid/client/perf/Options.java   | 1 +
 3 files changed, 5 insertions(+), 2 deletions(-)

(limited to 'qpid/java')

diff --git a/qpid/java/perftests/src/main/java/org/apache/qpid/client/perf/MessageConsumerTest.java b/qpid/java/perftests/src/main/java/org/apache/qpid/client/perf/MessageConsumerTest.java
index 52356ae243..116fb79246 100644
--- a/qpid/java/perftests/src/main/java/org/apache/qpid/client/perf/MessageConsumerTest.java
+++ b/qpid/java/perftests/src/main/java/org/apache/qpid/client/perf/MessageConsumerTest.java
@@ -10,6 +10,7 @@ import javax.jms.Destination;
 import javax.jms.Session;
 
 import org.apache.qpid.client.AMQConnection;
+import org.apache.qpid.client.AMQQueue;
 import org.apache.qpid.client.AMQTopic;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -47,7 +48,7 @@ public class MessageConsumerTest extends Options implements Runnable
     {
         AMQConnection con = ConnectionUtility.getInstance().getConnection();
         con.start();
-        Destination dest = new AMQTopic(con, routingKey);
+        Destination dest = Boolean.getBoolean("useQueue")? new AMQQueue(con,routingKey) : new AMQTopic(con,routingKey);
         JMSConsumer prod;
         if (_synchronous)
         {
diff --git a/qpid/java/perftests/src/main/java/org/apache/qpid/client/perf/MessageProducerTest.java b/qpid/java/perftests/src/main/java/org/apache/qpid/client/perf/MessageProducerTest.java
index b0ea28292d..1710c5ca09 100644
--- a/qpid/java/perftests/src/main/java/org/apache/qpid/client/perf/MessageProducerTest.java
+++ b/qpid/java/perftests/src/main/java/org/apache/qpid/client/perf/MessageProducerTest.java
@@ -10,6 +10,7 @@ import javax.jms.Connection;
 import javax.jms.Destination;
 
 import org.apache.qpid.client.AMQConnection;
+import org.apache.qpid.client.AMQQueue;
 import org.apache.qpid.client.AMQTopic;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -46,7 +47,7 @@ public class MessageProducerTest extends Options implements Runnable
     {
         AMQConnection con = ConnectionUtility.getInstance().getConnection();
         con.start();
-        Destination dest = new AMQTopic(con,routingKey);
+        Destination dest = Boolean.getBoolean("useQueue")? new AMQQueue(con,routingKey) : new AMQTopic(con,routingKey);
         JMSProducer prod = new JMSProducer(String.valueOf(_count),(Connection)con, dest,_messageSize, _transacted);
         Thread t = new Thread(prod);
         t.setName("JMSProducer-"+_count);
diff --git a/qpid/java/perftests/src/main/java/org/apache/qpid/client/perf/Options.java b/qpid/java/perftests/src/main/java/org/apache/qpid/client/perf/Options.java
index 7fddbbeeb7..2d04426794 100644
--- a/qpid/java/perftests/src/main/java/org/apache/qpid/client/perf/Options.java
+++ b/qpid/java/perftests/src/main/java/org/apache/qpid/client/perf/Options.java
@@ -15,6 +15,7 @@ public class Options
     /**
      * System props
      * -DmessageSize
+     * -DuseQueue
      * -Dtransacted
      * -DproducerCount
      * -DconsumerCount
-- 
cgit v1.2.1