meerkat
/
meerkat-java
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Pulled the first version of the BulletinBoardClientIntegretionTest file

Voter-Registry
Vladimir Eliezer Tokarev 2016-03-04 04:50:33 -08:00
parent 311d1e8e8e
commit 687c2c6d7e
1 changed files with 2 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
bulletin-board-client/src/test/java/BulletinBoardClientIntegrationTest.java
View File

@ -102,7 +102,7 @@ public class BulletinBoardClientIntegrationTest {
private ReadCallback readCallback; private ReadCallback readCallback;
private static String PROP_GETTY_URL = "gretty.httpBaseURI"; private static String PROP_GETTY_URL = "gretty.httpBaseURI";
private static String DEFAULT_BASE_URL = "http://localhost:3306"; private static String DEFAULT_BASE_URL = "http://localhost:8081";
private static String BASE_URL = System.getProperty(PROP_GETTY_URL, DEFAULT_BASE_URL); private static String BASE_URL = System.getProperty(PROP_GETTY_URL, DEFAULT_BASE_URL);
@Before @Before
@ -114,7 +114,7 @@ public class BulletinBoardClientIntegrationTest {
testDB.add(BASE_URL); testDB.add(BASE_URL);
bulletinBoardClient.init(BulletinBoardClientParams.newBuilder() bulletinBoardClient.init(BulletinBoardClientParams.newBuilder()
.addBulletinBoardAddress("http://localhost:3306") .addBulletinBoardAddress("http://localhost:8081")
.setMinRedundancy((float) 1.0) .setMinRedundancy((float) 1.0)
.build()); .build());
@ -163,8 +163,6 @@ public class BulletinBoardClientIntegrationTest {
messageID = bulletinBoardClient.postMessage(msg,postCallback); messageID = bulletinBoardClient.postMessage(msg,postCallback);
System.out.println(messageID.toByteArray());
try { try {
jobSemaphore.acquire(); jobSemaphore.acquire();
} catch (InterruptedException e) { } catch (InterruptedException e) {
@ -206,7 +204,6 @@ public class BulletinBoardClientIntegrationTest {
System.err.println(t.getMessage()); System.err.println(t.getMessage());
} }
if (thrown.size() > 0) { if (thrown.size() > 0) {
System.out.println(thrown.size());
assert false; assert false;
} }