diff options
| author | Martin Ritchie <ritchiem@apache.org> | 2008-10-09 17:43:41 +0000 |
|---|---|---|
| committer | Martin Ritchie <ritchiem@apache.org> | 2008-10-09 17:43:41 +0000 |
| commit | 205e035f834266257e383d17bd80d83abcc1fe2a (patch) | |
| tree | b23a70907351136dbd32e344d36ddc1d2b0b1440 /qpid/java/systests/src | |
| parent | a09ed43cc8ed5862996e684b924f3405e09734c3 (diff) | |
| download | qpid-python-205e035f834266257e383d17bd80d83abcc1fe2a.tar.gz | |
QPID-1331 : Modified the BrowserSubscription to be consistent with the NoAck Subscription.
Added Test QueueBrowserUsesNoAckTest to validate the change.
Note that the Credit Manager Suspends the subscriber not the channel when credit is exhausted. JIRA to follow.
So to check if the subscription was suspended I needed to make a MockChannel and give it access to the subscriber map in the
Channel.
The test also needed to be able to interrogate the state of the Subscription which was not part of the Subscription interface, but was used by all subscriptions. So promoted to the interface and implemented the stubs in the various helper/test classes.
Added the ability to browse() via the InternalBrokerBaseCase and prevented a NPE when there were no messages returned via getDelivers.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@703212 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/systests/src')
| -rw-r--r-- | qpid/java/systests/src/main/java/org/apache/qpid/server/queue/SubscriptionTestHelper.java | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/SubscriptionTestHelper.java b/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/SubscriptionTestHelper.java index eed60a1a7c..c20c0bc579 100644 --- a/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/SubscriptionTestHelper.java +++ b/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/SubscriptionTestHelper.java @@ -110,6 +110,12 @@ public class SubscriptionTestHelper implements Subscription { //To change body of implemented methods use File | Settings | File Templates. } + + @Override + public State getState() + { + return null; //To change body of implemented methods use File | Settings | File Templates. + } public QueueEntry getLastSeenEntry() { |