Vertx Java部署一个JavaScript verticle和将来的回调

Question

    Vertx.clusteredVertx(vertxOptions, res ->
    {
        if (res.succeeded()) {
            logger.info("Cluster ready, starting verticle deploy");
            /*
             * React JS Server Deploy
             */
            Future< String > reactVerticleFuture = Future.future();

            vertx.executeBlocking(future ->
            {
                vertx.deployVerticle("dist/server.js", options, deployResult ->
                {
                    if (deployResult.succeeded()) {
                        future.complete();
                    } else {
                        future.fail(deployResult.cause());
                    }
                });

            } , reactVerticleFuture.completer());

             CompositeFuture.all(..., reactVerticleFuture).setHandler(ar ->
            {
               /*
                * deploy http listener and health endpoint
                */
            });
        } else {
            logger.error(res.cause().getMessage(), res.cause());
        }
    });

exports.vertxStartAsync = function(startFuture) {

console.log('vertxStartAsync')

var eb = vertx.eventBus()
var consumer = eb.consumer('httpGetWebChannel', function (message) {
})

consumer.completionHandler(function (res, res_err) {
    if (res_err == null) {
        console.log("The handler registration has reached all nodes");

        startFuture.complete()
    } else {
        console.log("Registration failed!");

        startFuture.fail()
    }
});
}

我怎么才能修好这个？

谢谢马塞尔

Answer 1

好的，我们找到了解决方案（alexvetter-谢谢你的耐心）。

问题是，我用webpack构建Server.js文件，构建之后，exports块位于函数内部。

这是工作解决方案：

var WrapperPlugin = require('wrapper-webpack-plugin');

... 

plugins: [
        new WrapperPlugin({
            header: 'exports.vertxStartAsync = function(startFuture) {\n',
            footer: '}\n'
        }),
...
]
...

var eb = vertx.eventBus()
var consumer = eb.consumer('httpGetWebChannel', function (message) {
  ...
})

consumer.completionHandler(function (res, res_err) {
    if (res_err == null) {
        console.log("The handler registration has reached all nodes");

        startFuture.complete()
    } else {
        console.log("Registration failed!");

        startFuture.fail()
    }
});