如何在将vertx httpserver部署为worker verticle时获取等待处理的请求数？

// Worker Verticle
public class MyWorkerVerticle extends AbstractVerticle {
    public void start() {
        // 获取Event Bus实例
        EventBus eventBus = vertx.eventBus();

        // 发送"getPendingRequests"消息到HttpServer Verticle
        eventBus.send("httpServerVerticle", "getPendingRequests", reply -> {
            if (reply.succeeded()) {
                // 获取等待处理的请求数
                int pendingRequests = (int) reply.result().body();
                System.out.println("Pending requests: " + pendingRequests);
            } else {
                System.out.println("Failed to get pending requests: " + reply.cause().getMessage());
            }
        });
    }
}

// HttpServer Verticle
public class MyHttpServerVerticle extends AbstractVerticle {
    public void start() {
        // 创建一个本地Map，用于存储等待处理的请求
        LocalMap<String, Object> pendingRequests = vertx.sharedData().getLocalMap("pendingRequests");

        // 创建HttpServer并设置请求处理器
        HttpServer server = vertx.createHttpServer();
        server.requestHandler(request -> {
            // 处理请求

            // 将请求添加到等待处理的请求Map中
            pendingRequests.put(request.id(), request);

            // 处理请求...

            // 请求处理完成后，从Map中移除请求
            pendingRequests.remove(request.id());
        });

        // 监听"getPendingRequests"消息
        vertx.eventBus().consumer("httpServerVerticle", message -> {
            if ("getPendingRequests".equals(message.body())) {
                // 回复等待处理的请求数
                message.reply(pendingRequests.size());
            }
        });

        // 启动HttpServer
        server.listen(8080);
    }
}