summaryrefslogtreecommitdiff
path: root/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/client/ConsumerParticipant.java
diff options
context:
space:
mode:
Diffstat (limited to 'qpid/java/perftests/src/main/java/org/apache/qpid/disttest/client/ConsumerParticipant.java')
-rw-r--r--qpid/java/perftests/src/main/java/org/apache/qpid/disttest/client/ConsumerParticipant.java5
1 files changed, 3 insertions, 2 deletions
diff --git a/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/client/ConsumerParticipant.java b/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/client/ConsumerParticipant.java
index 7d68a8d84c..1b5e8276c2 100644
--- a/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/client/ConsumerParticipant.java
+++ b/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/client/ConsumerParticipant.java
@@ -65,6 +65,7 @@ public class ConsumerParticipant implements Participant
public ParticipantResult doIt(String registeredClientName) throws Exception
{
final Date start = new Date();
+ final int acknowledgeMode = _jmsDelegate.getAcknowledgeMode(_command.getSessionName());
if (_command.getMaximumDuration() == 0 && _command.getNumberOfMessages() == 0)
{
@@ -100,11 +101,11 @@ public class ConsumerParticipant implements Participant
getName(),
registeredClientName,
_command,
+ acknowledgeMode,
numberOfMessagesSent,
payloadSize,
totalPayloadSize,
- start,
- end);
+ start, end);
return result;
}