1. We just need to make sure to use the same event bus destination as the service that was published by .
    1. private void indexHandler(RoutingContext context) {
    2.   dbService.fetchAllPages(reply -> {
    3.     if (reply.succeeded()) {
    4.       context.put("title", "Wiki home");
    5.       context.put("pages", reply.result().getList());
    6.       templateEngine.render(context.data(), "templates/index.ftl", ar -> {
    7.         if (ar.succeeded()) {
    8.           context.response().putHeader("Content-Type", "text/html");
    9.           context.response().end(ar.result());
    10.         } else {
    11.           context.fail(ar.cause());
    12.         }
    13.       });
    14.     } else {
    15.       context.fail(reply.cause());
    16.     }
    17.   });
    18. }
    20. private void pageRenderingHandler(RoutingContext context) {
    21.   String requestedPage = context.request().getParam("page");
    22.   dbService.fetchPage(requestedPage, reply -> {
    23.     if (reply.succeeded()) {
    25.       JsonObject payLoad = reply.result();
    26.       boolean found = payLoad.getBoolean("found");
    27.       String rawContent = payLoad.getString("rawContent", EMPTY_PAGE_MARKDOWN);
    28.       context.put("title", requestedPage);
    29.       context.put("id", payLoad.getInteger("id", -1));
    31.       context.put("content", Processor.process(rawContent));
    32.       context.put("timestamp", new Date().toString());
    34.       templateEngine.render(context.data(), "templates/page.ftl", ar -> {
    35.         if (ar.succeeded()) {
    36.           context.response().putHeader("Content-Type", "text/html");
    37.           context.response().end(ar.result());
    38.         } else {
    39.           context.fail(ar.cause());
    40.         }
    41.       });
    43.     } else {
    44.       context.fail(reply.cause());
    45.     }
    46.   });
    47. }
    49. private void pageUpdateHandler(RoutingContext context) {
    50.   String title = context.request().getParam("title");
    52.   Handler<AsyncResult<Void>> handler = reply -> {
    53.     if (reply.succeeded()) {
    54.       context.response().setStatusCode(303);
    55.       context.response().putHeader("Location", "/wiki/" + title);
    56.       context.response().end();
    57.     } else {
    58.       context.fail(reply.cause());
    59.     }
    61.   String markdown = context.request().getParam("markdown");
    62.   if ("yes".equals(context.request().getParam("newPage"))) {
    63.     dbService.createPage(title, markdown, handler);
    64.   } else {
    65.     dbService.savePage(Integer.valueOf(context.request().getParam("id")), markdown, handler);
    66.   }
    67. }
    69. private void pageCreateHandler(RoutingContext context) {
    70.   String pageName = context.request().getParam("name");
    71.   String location = "/wiki/" + pageName;
    72.   if (pageName == null || pageName.isEmpty()) {
    73.     location = "/";
    74.   }
    75.   context.response().setStatusCode(303);
    76.   context.response().putHeader("Location", location);
    77.   context.response().end();
    78. }
    80. private void pageDeletionHandler(RoutingContext context) {
    81.   dbService.deletePage(Integer.valueOf(context.request().getParam("id")), reply -> {
    82.     if (reply.succeeded()) {
    83.       context.response().setStatusCode(303);
    84.       context.response().putHeader("Location", "/");
    85.       context.response().end();
    86.     } else {
    87.       context.fail(reply.cause());
    88.     }
    89.   });