Make CI happy

Author: dianw

.travis.yml

@@ -1,4 +1,3 @@
 language: java
 jdk:
-  - oraclejdk8
-  - oraclejdk7
+  - oraclejdk8

src/test/java/org/codenergic/eventbus/ConnectionTest.java

@@ -41,7 +41,7 @@ public void before() throws InterruptedException {
 	@Test
 	public void testOpenAndCloseConnectionAsynchronously() throws Exception {
 		EventBus eventBus = EventBus.newInstance(connectionAddress);
-		assertThat(eventBus.open().get(2, TimeUnit.SECONDS)).isEqualTo(eventBus);
+		assertThat(eventBus.open().get(5, TimeUnit.SECONDS)).isEqualTo(eventBus);
 		eventBus.close();
 	}
 
@@ -54,9 +54,9 @@ public void testOpenAndCloseConnectionSynchronously() throws Exception {
 		eventBus.onClose((eb) -> connectionOpen.add(false));
 
 		assertThat(eventBus.openSync()).isEqualTo(eventBus);
-		assertThat(connectionOpen.poll(2, TimeUnit.SECONDS)).isNotNull().isTrue();
+		assertThat(connectionOpen.poll(5, TimeUnit.SECONDS)).isNotNull().isTrue();
 
 		eventBus.close();
-		assertThat(connectionOpen.poll(2, TimeUnit.SECONDS)).isNotNull().isFalse();
+		assertThat(connectionOpen.poll(5, TimeUnit.SECONDS)).isNotNull().isFalse();
 	}
 }

src/test/java/org/codenergic/eventbus/SendMessageTest.java

@@ -72,7 +72,7 @@ public void testPublishAndSubscribe() throws InterruptedException {
 
 		eventBus.publish("test-address", body, headers);
 
-		boolean completed = latch.await(2, TimeUnit.SECONDS);
+		boolean completed = latch.await(5, TimeUnit.SECONDS);
 		assertThat(completed).isTrue();
 
 		assertThat(messages).hasSize(2);
@@ -99,7 +99,7 @@ public void testSendAndSubscribe() throws InterruptedException {
 		eventBus.send("test-address", body, headers);
 		eventBus.send("test-address", body);
 
-		boolean completed = latch.await(2, TimeUnit.SECONDS);
+		boolean completed = latch.await(5, TimeUnit.SECONDS);
 		assertThat(completed).isTrue();
 
 		assertThat(messages).hasSize(2);
@@ -127,7 +127,7 @@ public void testSendMessageWithReply() throws InterruptedException {
 			});
 		});
 
-		boolean sent = latch.await(2, TimeUnit.SECONDS);
+		boolean sent = latch.await(5, TimeUnit.SECONDS);
 		assertThat(sent).isTrue();
 		assertThat(messages.size()).isEqualTo(messageBodies.size());
 
@@ -166,7 +166,7 @@ public void testSubscribeAndThrowError() throws InterruptedException {
 		}));
 		eventBus.send("test-address", body);
 
-		assertThat(latch.await(1, TimeUnit.SECONDS)).isTrue();
+		assertThat(latch.await(5, TimeUnit.SECONDS)).isTrue();
 
 		assertThat(messages).hasSize(2);
 		messages.forEach(message -> assertThat(message.getBody()).isEqualTo("test-address-" + body));
@@ -187,13 +187,13 @@ public void testSubscribeAndUnsubscribe() throws InterruptedException {
 		eventBus.registerHandler("test-address-publish-reply", messageHandler);
 		eventBus.publish("test-address", "testing");
 
-		boolean sent = latch.await(1, TimeUnit.SECONDS);
+		boolean sent = latch.await(5, TimeUnit.SECONDS);
 		assertThat(sent).isFalse();
 
 		eventBus.unregisterHandler("test-address-publish-reply", messageHandler);
 		eventBus.publish("test-address", "testing");
 
-		sent = latch.await(1, TimeUnit.SECONDS);
+		sent = latch.await(5, TimeUnit.SECONDS);
 		assertThat(sent).isFalse();
 
 		assertThat(messages).hasSize(1);