diff options
| author | Keith Wall <kwall@apache.org> | 2011-11-17 10:14:23 +0000 |
|---|---|---|
| committer | Keith Wall <kwall@apache.org> | 2011-11-17 10:14:23 +0000 |
| commit | cb9171ae93470d8953bd54312bd3b9aab97c8da7 (patch) | |
| tree | 94282e4b63317a348d11072f4e22d149e97795e0 /qpid/java/broker/src/test | |
| parent | 5fdfa5d5437968958b792eb4f17489b10db75a58 (diff) | |
| download | qpid-python-cb9171ae93470d8953bd54312bd3b9aab97c8da7.tar.gz | |
QPID-2703: 0-8..0-9-1 Transaction rollback/recover does not restore consumer credit.
This change restores consumer credit after rollback/recover by restoring credit on reciept of basic.reject from the consumer.
This change is basically as QPID-2506, but with additional changes to avoid the 0-10 path. Work by Robbie Gemmell and myself.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1203137 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/broker/src/test')
| -rw-r--r-- | qpid/java/broker/src/test/java/org/apache/qpid/server/subscription/MockSubscription.java | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/qpid/java/broker/src/test/java/org/apache/qpid/server/subscription/MockSubscription.java b/qpid/java/broker/src/test/java/org/apache/qpid/server/subscription/MockSubscription.java index 6fbc627d8c..1efe1028db 100644 --- a/qpid/java/broker/src/test/java/org/apache/qpid/server/subscription/MockSubscription.java +++ b/qpid/java/broker/src/test/java/org/apache/qpid/server/subscription/MockSubscription.java @@ -212,6 +212,10 @@ public class MockSubscription implements Subscription { } + public void releaseQueueEntry(QueueEntry queueEntry) + { + } + public void send(QueueEntry entry) throws AMQException { if (messages.contains(entry)) |