jlengrand/vert.x
1
0
Fork 0
mirror of https://github.com/jlengrand/vert.x.git synced 2026-03-10 08:51:19 +00:00
Code Issues Packages Projects Releases Wiki Activity

Test MessageProducer end/close methods with no/null handler

Browse Source
This commit is contained in:
Julien Viet
2019-06-28 09:09:14 +02:00
parent af7513ee74
commit c78b8a14fb
2 changed files with 25 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/io/vertx/core/eventbus/impl/MessageProducerImpl.java
View File

@@ -147,7 +147,11 @@ public class MessageProducerImpl<T> implements MessageProducer<T> {
if (creditConsumer != null) {
creditConsumer.unregister(handler);
} else {
vertx.runOnContext(v -> handler.handle(Future.succeededFuture()));
vertx.runOnContext(v -> {
if (handler != null) {
handler.handle(Future.succeededFuture());
}
});
}
}

20
src/test/java/io/vertx/core/eventbus/LocalEventBusTest.java
View File

@@ -1272,6 +1272,26 @@ public class LocalEventBusTest extends EventBusTestBase {
await();
}
@Test
public void testCloseSender1() {
eb.sender(ADDRESS1).close();
}
@Test
public void testCloseSender2() {
eb.sender(ADDRESS1).close(null);
}
@Test
public void testClosePublisher1() {
eb.publisher(ADDRESS1).close();
}
@Test
public void testClosePublisher2() {
eb.publisher(ADDRESS1).close(null);
}
@Test
public void testPump() {
String str = TestUtils.randomUnicodeString(100);