summaryrefslogtreecommitdiff
path: root/java/systests/src/test/java/org/apache/qpid/server/queue/SubscriptionManagerTest.java
diff options
context:
space:
mode:
Diffstat (limited to 'java/systests/src/test/java/org/apache/qpid/server/queue/SubscriptionManagerTest.java')
-rw-r--r--java/systests/src/test/java/org/apache/qpid/server/queue/SubscriptionManagerTest.java18
1 files changed, 9 insertions, 9 deletions
diff --git a/java/systests/src/test/java/org/apache/qpid/server/queue/SubscriptionManagerTest.java b/java/systests/src/test/java/org/apache/qpid/server/queue/SubscriptionManagerTest.java
index f8db90850f..d3ec3c11d4 100644
--- a/java/systests/src/test/java/org/apache/qpid/server/queue/SubscriptionManagerTest.java
+++ b/java/systests/src/test/java/org/apache/qpid/server/queue/SubscriptionManagerTest.java
@@ -30,12 +30,12 @@ public class SubscriptionManagerTest extends TestCase
{
assertTrue(mgr.isEmpty());
assertFalse(mgr.hasActiveSubscribers());
- TestSubscription s1 = new TestSubscription("S1");
+ SubscriptionTestHelper s1 = new SubscriptionTestHelper("S1");
mgr.addSubscriber(s1);
assertFalse(mgr.isEmpty());
assertTrue(mgr.hasActiveSubscribers());
- TestSubscription s2 = new TestSubscription("S2");
+ SubscriptionTestHelper s2 = new SubscriptionTestHelper("S2");
mgr.addSubscriber(s2);
s2.setSuspended(true);
@@ -47,18 +47,18 @@ public class SubscriptionManagerTest extends TestCase
s1.setSuspended(true);
assertFalse(mgr.hasActiveSubscribers());
- mgr.removeSubscriber(new TestSubscription("S1"));
+ mgr.removeSubscriber(new SubscriptionTestHelper("S1"));
assertFalse(mgr.isEmpty());
- mgr.removeSubscriber(new TestSubscription("S2"));
+ mgr.removeSubscriber(new SubscriptionTestHelper("S2"));
assertTrue(mgr.isEmpty());
}
public void testRoundRobin()
{
- TestSubscription a = new TestSubscription("A");
- TestSubscription b = new TestSubscription("B");
- TestSubscription c = new TestSubscription("C");
- TestSubscription d = new TestSubscription("D");
+ SubscriptionTestHelper a = new SubscriptionTestHelper("A");
+ SubscriptionTestHelper b = new SubscriptionTestHelper("B");
+ SubscriptionTestHelper c = new SubscriptionTestHelper("C");
+ SubscriptionTestHelper d = new SubscriptionTestHelper("D");
mgr.addSubscriber(a);
mgr.addSubscriber(b);
mgr.addSubscriber(c);
@@ -84,7 +84,7 @@ public class SubscriptionManagerTest extends TestCase
mgr.removeSubscriber(a);
d.setSuspended(true);
c.setSuspended(false);
- Subscription e = new TestSubscription("D");
+ Subscription e = new SubscriptionTestHelper("D");
mgr.addSubscriber(e);
for (int i = 0; i < 3; i++)