tweaked tests
This commit is contained in:
parent
6582caa521
commit
673e9300ff
|
@ -98,6 +98,8 @@ class ReconnectTest extends BaseTest {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
server.bind(false);
|
||||||
|
|
||||||
|
|
||||||
// ----
|
// ----
|
||||||
|
|
||||||
|
@ -131,7 +133,7 @@ class ReconnectTest extends BaseTest {
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
server.bind(false);
|
|
||||||
|
|
||||||
int count = 100;
|
int count = 100;
|
||||||
int initialCount = 2;
|
int initialCount = 2;
|
||||||
|
@ -149,7 +151,7 @@ class ReconnectTest extends BaseTest {
|
||||||
synchronized (receivedCount) {
|
synchronized (receivedCount) {
|
||||||
while (this.receivedCount.get() != target) {
|
while (this.receivedCount.get() != target) {
|
||||||
if (waitingRetryCount-- < 0) {
|
if (waitingRetryCount-- < 0) {
|
||||||
System.out.println("Aborting...");
|
System.out.println("Aborting unit test... wrong count!");
|
||||||
stopEndPoints();
|
stopEndPoints();
|
||||||
assertEquals(target, this.receivedCount.get());
|
assertEquals(target, this.receivedCount.get());
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue
Block a user