private void doRedeploy(final JsonObject deploymentInfo) {
    if (deploymentInfo.getString("type").equals("module")) {
      log.info(String.format("%s - redeploying module %s", DefaultGroupManager.this, deploymentInfo.getString("module")));
      final CountDownLatch latch = new CountDownLatch(1);
      platform.deployModule(deploymentInfo.getString("module"), deploymentInfo.getObject("config", new JsonObject()), deploymentInfo.getInteger("instances", 1), createRedeployHandler(deploymentInfo, latch));
      try {
        latch.await(10, TimeUnit.SECONDS);
      } catch (InterruptedException e) {
      }
    } else if (deploymentInfo.getString("type").equals("verticle")) {
      log.info(String.format("%s - redeploying verticle %s", DefaultGroupManager.this, deploymentInfo.getString("main")));
      final CountDownLatch latch = new CountDownLatch(1);
      if (deploymentInfo.getBoolean("worker", false)) {
        platform.deployWorkerVerticle(deploymentInfo.getString("main"), deploymentInfo.getObject("config", new JsonObject()), deploymentInfo.getInteger("instances", 1), deploymentInfo.getBoolean("multi-threaded"), createRedeployHandler(deploymentInfo, latch));
      } else {
        platform.deployVerticle(deploymentInfo.getString("main"), deploymentInfo.getObject("config", new JsonObject()), deploymentInfo.getInteger("instances", 1), createRedeployHandler(deploymentInfo, latch));
      }
      try {
        latch.await(10, TimeUnit.SECONDS);
      } catch (InterruptedException e) {
      }
    }
  }
private void doRedeploy ( final JsonObject deploymentInfo ) { if ( deploymentInfo . getString ( "type" ) . equals ( "module" ) ) { log . info ( String . format ( "%s - redeploying module %s" , DefaultGroupManager . this , deploymentInfo . getString ( "module" ) ) ) ; final CountDownLatch latch = new CountDownLatch ( 1 ) ; platform . deployModule ( deploymentInfo . getString ( "module" ) , deploymentInfo . getObject ( "config" , new JsonObject ( ) ) , deploymentInfo . getInteger ( "instances" , 1 ) , createRedeployHandler ( deploymentInfo , latch ) ) ; try { latch . await ( 10 , TimeUnit . SECONDS ) ; } catch ( InterruptedException e ) { } } else if ( deploymentInfo . getString ( "type" ) . equals ( "verticle" ) ) { log . info ( String . format ( "%s - redeploying verticle %s" , DefaultGroupManager . this , deploymentInfo . getString ( "main" ) ) ) ; final CountDownLatch latch = new CountDownLatch ( 1 ) ; if ( deploymentInfo . getBoolean ( "worker" , false ) ) { platform . deployWorkerVerticle ( deploymentInfo . getString ( "main" ) , deploymentInfo . getObject ( "config" , new JsonObject ( ) ) , deploymentInfo . getInteger ( "instances" , 1 ) , deploymentInfo . getBoolean ( "multi-threaded" ) , createRedeployHandler ( deploymentInfo , latch ) ) ; } else { platform . deployVerticle ( deploymentInfo . getString ( "main" ) , deploymentInfo . getObject ( "config" , new JsonObject ( ) ) , deploymentInfo . getInteger ( "instances" , 1 ) , createRedeployHandler ( deploymentInfo , latch ) ) ; } try { latch . await ( 10 , TimeUnit . SECONDS ) ; } catch ( InterruptedException e ) { } } }
Redeploys a deployment.