From 4b1efc5908b5a8c5a9bc274f7a8e8ff2d5ddccab Mon Sep 17 00:00:00 2001 From: Rajith Muditha Attapattu Date: Wed, 16 Jan 2008 22:21:07 +0000 Subject: Fixed various compilation errors git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@612593 13f79535-47bb-0310-9956-ffa450edef68 --- .../main/java/org/apache/qpid/client/perf/MessageConsumerTest.java | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) (limited to 'java/perftests/src') diff --git a/java/perftests/src/main/java/org/apache/qpid/client/perf/MessageConsumerTest.java b/java/perftests/src/main/java/org/apache/qpid/client/perf/MessageConsumerTest.java index a618a6599d..1124e070a1 100644 --- a/java/perftests/src/main/java/org/apache/qpid/client/perf/MessageConsumerTest.java +++ b/java/perftests/src/main/java/org/apache/qpid/client/perf/MessageConsumerTest.java @@ -40,11 +40,7 @@ public class MessageConsumerTest extends Options implements MessageListener Destination dest = Boolean.getBoolean("useQueue")? new AMQQueue(_connection,_destination) : new AMQTopic(_connection,_destination); _session = _connection.createSession(_transacted, Session.AUTO_ACKNOWLEDGE); MessageConsumer _consumer = _session.createConsumer(dest); - if(!_synchronous) - { - _consumer.setMessageListener(this); - } - + _consumer.setMessageListener(this); _startTime = System.currentTimeMillis(); if(Boolean.getBoolean("collect_stats")) { -- cgit v1.2.1