diff options
| author | Rajith Muditha Attapattu <rajith@apache.org> | 2007-11-28 19:47:26 +0000 |
|---|---|---|
| committer | Rajith Muditha Attapattu <rajith@apache.org> | 2007-11-28 19:47:26 +0000 |
| commit | ec2e89d1807d6dad9d678e2043c5f0e8c85d07c8 (patch) | |
| tree | 9d10ac1ef0f3c4d2cfe9453f0fe825d8f87315c6 /qpid/java/perftests/src | |
| parent | 051732dce020995e984323559b6d210025a1529b (diff) | |
| download | qpid-python-ec2e89d1807d6dad9d678e2043c5f0e8c85d07c8.tar.gz | |
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
Diffstat (limited to 'qpid/java/perftests/src')
3 files changed, 5 insertions, 2 deletions
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 |