diff options
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 |