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 | 4b1efc5908b5a8c5a9bc274f7a8e8ff2d5ddccab (patch) | |
| tree | 8ed105406708cde64ccc8d0d6f6dfb7163fed6fd /java/perftests/src | |
| parent | 648f1a6384730ccf3183d3507663c849d98f19f0 (diff) | |
| download | qpid-python-4b1efc5908b5a8c5a9bc274f7a8e8ff2d5ddccab.tar.gz | |
Fixed various compilation errors
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@612593 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/perftests/src')
| -rw-r--r-- | java/perftests/src/main/java/org/apache/qpid/client/perf/MessageConsumerTest.java | 6 |
1 files changed, 1 insertions, 5 deletions
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")) { |