diff options
| author | Aidan Skinner <aidan@apache.org> | 2008-08-05 11:10:28 +0000 |
|---|---|---|
| committer | Aidan Skinner <aidan@apache.org> | 2008-08-05 11:10:28 +0000 |
| commit | 5a245b5b3b7e787a2163bd782d67e94d255a9957 (patch) | |
| tree | 0daba5307f5bcfb51ca5153afbd43a84de9d9c34 /java/perftests | |
| parent | 6f0c723706e09a9333288c139045276537aa5dc6 (diff) | |
| download | qpid-python-5a245b5b3b7e787a2163bd782d67e94d255a9957.tar.gz | |
QPID-1206: Fix failover and failover tests
AMQConnection: remove dead and confusingly misnamed method
AMQSession: rename failedOver to failedOverDirty to convey actual usage, only set it if we failed over while dirty. Ewww!
BasicMessageConsumer: if we're in client ack mode, mark as dirty when we receive a message
PingPongProducer: calculate expected replies properly if we fail after a send or before a commit
FailoverTest: test transacted case
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@682672 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/perftests')
| -rw-r--r-- | java/perftests/src/main/java/org/apache/qpid/requestreply/PingPongProducer.java | 8 |
1 files changed, 3 insertions, 5 deletions
diff --git a/java/perftests/src/main/java/org/apache/qpid/requestreply/PingPongProducer.java b/java/perftests/src/main/java/org/apache/qpid/requestreply/PingPongProducer.java index 4d8a736ec8..f994cd138e 100644 --- a/java/perftests/src/main/java/org/apache/qpid/requestreply/PingPongProducer.java +++ b/java/perftests/src/main/java/org/apache/qpid/requestreply/PingPongProducer.java @@ -1673,11 +1673,9 @@ public class PingPongProducer implements Runnable, ExceptionListener */ public int getExpectedNumPings(int numpings) { - // log.debug("public int getExpectedNumPings(int numpings = " + numpings + "): called"); - - // log.debug("Each ping will be received by " + (_isPubSub ? getConsumersPerDestination() : 1) + " consumers."); - - return numpings * (_isPubSub ? getConsumersPerDestination() : 1); + // Wow, I'm freaking sorry about this return here... + return ((_failAfterSend || _failBeforeCommit) ? numpings - 1: numpings) * + (_isPubSub ? getConsumersPerDestination() : 1); } /** |