mirror of https://github.com/apache/activemq.git
fix up test case
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1404830 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
af4edb335a
commit
5e03927da7
|
@ -75,12 +75,12 @@ public class DurableSubscriptionRemoveOfflineTest extends EmbeddedBrokerTestSupp
|
|||
subscriber.close();
|
||||
connection.close();
|
||||
|
||||
Wait.waitFor(new Wait.Condition() {
|
||||
assertTrue(Wait.waitFor(new Wait.Condition() {
|
||||
@Override
|
||||
public boolean isSatisified() throws Exception {
|
||||
return broker.getAdminView().getInactiveDurableTopicSubscribers().length == 0;
|
||||
}
|
||||
}, 15000);
|
||||
}, 15000));
|
||||
}
|
||||
|
||||
public void testRemoveAfterRestart() throws Exception {
|
||||
|
|
Loading…
Reference in New Issue