Package io.vertx.core

Examples of io.vertx.core.DeploymentOptions

560
561
562
563
564
565
566
567
568
569
570
  }

  @Test
  public void testDeployUndeployMultipleInstancesUsingClassName() throws Exception {
    int numInstances = 10;
    DeploymentOptions options = new DeploymentOptions().setInstances(numInstances);
    AtomicInteger deployCount = new AtomicInteger();
    AtomicInteger undeployCount = new AtomicInteger();
    AtomicInteger deployHandlerCount = new AtomicInteger();
    AtomicInteger undeployHandlerCount = new AtomicInteger();
    vertx.eventBus().<String>consumer("tvstarted").handler(msg -> {
View Full Code Here
847
848
849
850
851
852
853
854
855
856
857
    await();
  }

  @Test
  public void testIsolationGroup1() throws Exception {
    vertx.deployVerticle("java:" + TestVerticle.class.getCanonicalName(), new DeploymentOptions().setIsolationGroup("somegroup"), ar -> {
      assertTrue(ar.succeeded());
      assertEquals(0, TestVerticle.instanceCount.get());
      testComplete();
    });
    await();
View Full Code Here
857
858
859
860
861
862
863
864
865
866
867
    await();
  }

  @Test
  public void testNullIsolationGroup() throws Exception {
    vertx.deployVerticle("java:" + TestVerticle.class.getCanonicalName(), new DeploymentOptions().setIsolationGroup(null), ar -> {
      assertTrue(ar.succeeded());
      assertEquals(1, TestVerticle.instanceCount.get());
      testComplete();
    });
    await();
View Full Code Here
880
881
882
883
884
885
886
887
888
889
890
  @Test
  public void testExtraClasspath() throws Exception {
    String cp1 = "foo/bar/wibble";
    String cp2 = "blah/socks/mice";
    List<String> extraClasspath = Arrays.asList(cp1, cp2);
    vertx.deployVerticle("java:" + TestVerticle.class.getCanonicalName(), new DeploymentOptions().setIsolationGroup("somegroup").
      setExtraClasspath(extraClasspath), ar -> {
      assertTrue(ar.succeeded());
      Deployment deployment = ((VertxInternal) vertx).getDeployment(ar.result());
      Verticle verticle = deployment.getVerticles().iterator().next();
      ClassLoader cl = verticle.getClass().getClassLoader();
View Full Code Here
982
983
984
985
986
987
988
989
990
991
992
993
994
995
996
      countMap.put(msg.body().getString("deploymentID"), msg.body().getInteger("count"));
    });
    CountDownLatch latch = new CountDownLatch(1);
    AtomicReference<String> deploymentID1 = new AtomicReference<>();
    AtomicReference<String> deploymentID2 = new AtomicReference<>();
    vertx.deployVerticle("java:" + TestVerticle.class.getCanonicalName(), new DeploymentOptions().setIsolationGroup(group1), ar -> {
      assertTrue(ar.succeeded());
      deploymentID1.set(ar.result());
      assertEquals(0, TestVerticle.instanceCount.get());
      vertx.deployVerticle("java:" + TestVerticle.class.getCanonicalName(), new DeploymentOptions().setIsolationGroup(group2), ar2 -> {
        assertTrue(ar2.succeeded());
        deploymentID2.set(ar2.result());
        assertEquals(0, TestVerticle.instanceCount.get());
        latch.countDown();
      });
View Full Code Here
477
478
479
480
481
482
483
    });
  }

  @Override
  public void deployVerticle(Verticle verticle) {
    deployVerticle(verticle, new DeploymentOptions(), null);
  }
View Full Code Here
482
483
484
485
486
487
488
    deployVerticle(verticle, new DeploymentOptions(), null);
  }

  @Override
  public void deployVerticle(Verticle verticle, Handler<AsyncResult<String>> completionHandler) {
    deployVerticle(verticle, new DeploymentOptions(), completionHandler);
  }
View Full Code Here
487
488
489
490
491
492
493
    deployVerticle(verticle, new DeploymentOptions(), completionHandler);
  }

  @Override
  public void deployVerticle(String identifier, Handler<AsyncResult<String>> completionHandler) {
    deployVerticle(identifier, new DeploymentOptions(), completionHandler);
  }
View Full Code Here
502
503
504
505
506
507
508
    deploymentManager.deployVerticle(verticle, options, completionHandler);
  }

  @Override
  public void deployVerticle(String identifier) {
    deployVerticle(identifier, new DeploymentOptions(), null);
  }
View Full Code Here
TOP

Related Classes of io.vertx.core.DeploymentOptions

  • com.englishtown.vertx.jersey.integration.JerseyIntegrationTestBase
  • io.vertx.core.impl.HAManager
  • io.vertx.core.impl.VertxImpl
  • io.vertx.core.json.JsonArray
  • io.vertx.core.json.JsonObject
  • io.vertx.test.core.AbstractVerticleTest
  • io.vertx.test.core.ComplexHATest
  • io.vertx.test.core.DatagramTest
  • io.vertx.test.core.DeploymentTest
  • io.vertx.test.core.DNSTest
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.