Merge pull request #63 from Ako-Njang/java-vertx-4

update to java vertx 4.1.2
vert-x3 · Apr 20, 2022 · d43e37b · d43e37b
2 parents ca2c3dd + a368a66
commit d43e37b
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 6 deletions.
diff --git a/java/pom.xml b/java/pom.xml
@@ -32,10 +32,10 @@
   </scm>
 
   <properties>
-    <netty.version>4.1.52.Final</netty.version>
+    <netty.version>4.1.74.Final</netty.version>
     <gson.version>2.2.4</gson.version>
-    <jackson.version>2.11.3</jackson.version>
-    <vertx.version>3.9.5</vertx.version>
+    <jackson.version>2.13.1</jackson.version>
+    <vertx.version>4.2.7</vertx.version>
     <asciidoc.dir>${project.basedir}/src/main/asciidoc</asciidoc.dir>
   </properties>
 

diff --git a/java/src/test/java/io/vertx/eventbusclient/test/TcpBusTest.java b/java/src/test/java/io/vertx/eventbusclient/test/TcpBusTest.java
@@ -200,7 +200,7 @@ public void handle(Message<Object> event) {
     client.send("send_to_client", Collections.emptyMap());
     Async async2 = ctx.async();
     vertx.eventBus().consumer("send_to_client_fail", msg -> {
-      vertx.eventBus().send("client_addr", new JsonObject().put("message", "hello"), ar -> {
+      vertx.eventBus().request("client_addr", new JsonObject().put("message", "hello"), ar -> {
         ctx.assertFalse(ar.succeeded());
         ReplyException err = (ReplyException) ar.cause();
         ctx.assertEquals(ReplyFailure.NO_HANDLERS, err.failureType());

diff --git a/java/src/test/java/io/vertx/eventbusclient/test/WebSocketBusTest.java b/java/src/test/java/io/vertx/eventbusclient/test/WebSocketBusTest.java
@@ -65,13 +65,13 @@ protected void setUpBridges(TestContext ctx) {
     Router bridgeRouter = ebHandler.bridge(opts);
     router.mountSubRouter("/eventbus-test/", bridgeRouter);
     HttpServer server = vertx.createHttpServer(new HttpServerOptions().setMaxWebSocketFrameSize(MAX_WEBSOCKET_FRAME_SIZE).setMaxWebSocketMessageSize(MAX_WEBSOCKET_FRAME_SIZE))
-      .requestHandler(router::accept)
+      .requestHandler(router)
       .listen(7000, ctx.asyncAssertSuccess());
 
     vertx.createHttpServer(new HttpServerOptions().setMaxWebSocketFrameSize(MAX_WEBSOCKET_FRAME_SIZE).setMaxWebSocketMessageSize(MAX_WEBSOCKET_FRAME_SIZE).setSsl(true).setKeyStoreOptions(
       new JksOptions().setPath("server-keystore.jks").setPassword("wibble")
     ))
-      .requestHandler(router::accept)
+      .requestHandler(router)
       .listen(7001, ctx.asyncAssertSuccess());
 
     ctx.put("bridge", server);