vertx-eventbus-bridge-clients test

TcpBusTest.java

  @Test
  public void testSubscribeString(final TestContext ctx) throws Exception {
    final Async async = ctx.async();
    final EventBusClient client = client(ctx);
    client.consumer("client_addr", new Handler<Message<Object>>() {
      @Override
      public void handle(Message<Object> event) {
        ctx.assertEquals("hello", event.body());
        async.complete();
        client.close();
      }
    });
    vertx.eventBus().consumer("send_to_client", msg -> {
      vertx.eventBus().send("client_addr", "hello");
    });
    client.send("send_to_client", new HashMap<>());
  }