diff options
| author | Rajith Muditha Attapattu <rajith@apache.org> | 2008-01-16 22:21:07 +0000 |
|---|---|---|
| committer | Rajith Muditha Attapattu <rajith@apache.org> | 2008-01-16 22:21:07 +0000 |
| commit | f16667452555db6516ab047c41fdf7a597572391 (patch) | |
| tree | a585371dedf4e3705f89ed74b0645488c79ed9eb /qpid/java/perftests | |
| parent | a3d6f1353e838c5baab6d2cec116ec5acb06d2bd (diff) | |
| download | qpid-python-f16667452555db6516ab047c41fdf7a597572391.tar.gz | |
Fixed various compilation errors
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@612593 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/perftests')
| -rw-r--r-- | qpid/java/perftests/src/main/java/org/apache/qpid/client/perf/MessageConsumerTest.java | 6 |
1 files changed, 1 insertions, 5 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 a618a6599d..1124e070a1 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 @@ -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")) { |