import org.vertx.java.platform.PlatformManager; //导入依赖的package包/类
private static PlatformManager connectMain(int instances) throws MalformedURLException, InterruptedException {
    System.out.println(System.getProperty("vertx.langs.spring"));
    final CountDownLatch waitForDeploy = new CountDownLatch(2);
    pm.deployModule("org.jacpfx.vertx.spring~vertx-spring-mongo-application~1.0-SNAPSHOT",
            null,
            instances,
            (event) -> {
                if (event.succeeded()) waitForDeploy.countDown();
            });
    pm.deployVerticle("spring:org.jacpfx.vertx.spring.services.RESTGetVerticleService",
            null,
            new URL[]{new File(".").toURI().toURL()},
            instances,
            null,
            (event) -> {
                if (event.succeeded()) waitForDeploy.countDown();
            });
    waitForDeploy.await(10000, TimeUnit.MILLISECONDS);
    return pm;

}
 

import org.vertx.java.platform.PlatformManager; //导入依赖的package包/类
/** It starts vertx and deploys this project module */
public static void main(String[] args) throws InterruptedException, IOException {

   PlatformManager pm = PlatformLocator.factory.createPlatformManager(5558,"localhost");
   
   pm.deployModule("com.chuidiang.examples~vertx~1.0.0", null, 1, new Handler<AsyncResult<String>>() {
      
      @Override
      public void handle(AsyncResult<String> arg0) {
         System.out.println("module deploying result "+arg0.result());
      }
   });
}
 

import org.vertx.java.platform.PlatformManager; //导入依赖的package包/类
private static PlatformManager connectMain(int instances) throws MalformedURLException, InterruptedException {

        final CountDownLatch waitForDeploy = new CountDownLatch(1);
        pm.deployVerticle("org.jacpfx.vertx.spring.rest.RestEntryVerticle",
                null,
                new URL[]{new File(".").toURI().toURL()},
                instances,
                null,
                (event) -> {
                    if (event.succeeded()) waitForDeploy.countDown();
                });
        waitForDeploy.await(1000, TimeUnit.MILLISECONDS);
        return pm;

    }
 

import org.vertx.java.platform.PlatformManager; //导入依赖的package包/类
private static PlatformManager connect(int instances) throws MalformedURLException, InterruptedException {

        final CountDownLatch waitForDeploy = new CountDownLatch(1);
        pm.deployVerticle("org.jacpfx.vertx.spring.rest.RestEntryVerticle",
                null,
                new URL[]{new File(".").toURI().toURL()},
                instances,
                null,
                (event) -> {
                    if (event.succeeded()) waitForDeploy.countDown();
                });
        waitForDeploy.await(1000, TimeUnit.MILLISECONDS);
        return pm;

    }
 

import org.vertx.java.platform.PlatformManager; //导入依赖的package包/类
private static PlatformManager connect(int instances) throws MalformedURLException, InterruptedException {

        final CountDownLatch waitForDeploy = new CountDownLatch(1);
        pm.deployVerticle("spring:org.jacpfx.vertx.spring.ws.WSEntryVerticle",
                null,
                new URL[]{new File(".").toURI().toURL()},
                instances,
                null,
                (event) -> {
                    if (event.succeeded()) waitForDeploy.countDown();
                });
        waitForDeploy.await(1000, TimeUnit.MILLISECONDS);
        return pm;

    }
 

import org.vertx.java.platform.PlatformManager; //导入依赖的package包/类
@Override
public void start(StartContext context) throws StartException {
    ServiceTarget target = context.getChildTarget();
    VertxService vertxSvc = new VertxService();
    target.addService(VERTX, vertxSvc)
            .addDependency(VERTX_PLATFORM_MANAGER, PlatformManager.class, vertxSvc.platformManagerInjector())
            .install();

    target.addService(VERTX_PLATFORM_MANAGER, new PlatformManagerService())
            .install();
}
 

import org.vertx.java.platform.PlatformManager; //导入依赖的package包/类
public Injector<PlatformManager> platformManagerInjector() {
    return this.platformManagerInjector;
}
 

import org.vertx.java.platform.PlatformManager; //导入依赖的package包/类
@Override
public PlatformManager getValue() throws IllegalStateException, IllegalArgumentException {
    return this.platformManager;
}