diff options
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.java | 5 |
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; } |