public void start()

in services/tracking-service/reactive-vertx/src/main/java/com/amazon/BootStrapVerticle.java [45:84]


    public void start(Promise<Void> startFuture) {

        String trustStoreLocation = getenv("javax.net.ssl.trustStore");
        String trustAnchorsLocation = getenv("javax.net.ssl.trustAnchors");

        if (null != trustStoreLocation) {
            LOGGER.info("Setting javax.net.ssl.trustStore to " + trustStoreLocation);
            System.setProperty("javax.net.ssl.trustStore", trustStoreLocation);
        } else {
            LOGGER.info("Setting javax.net.ssl.trustStore not set");
        }

        if (null != trustAnchorsLocation) {
            LOGGER.info("Setting javax.net.ssl.trustAnchors to " + trustAnchorsLocation);
            System.setProperty("javax.net.ssl.trustAnchors", trustAnchorsLocation);
        } else {
            LOGGER.info("Setting javax.net.ssl.trustAnchors not set");
        }

        final List<Future> futures = new ArrayList<>(4);

        LOGGER.info("Deploying " + RedisVerticle.class.getCanonicalName());
        futures.add(vertx.deployVerticle(RedisVerticle.class, new DeploymentOptions().setInstances(1)));

        LOGGER.info("Deploying " + CacheVerticle.class.getCanonicalName());
        futures.add(vertx.deployVerticle(CacheVerticle.class, new DeploymentOptions().setInstances(1)));

        LOGGER.info("Deploying " + HttpVerticle.class.getCanonicalName());
        futures.add(vertx.deployVerticle(HttpVerticle.class, new DeploymentOptions().setInstances(5)));

        LOGGER.info("Deploying " + KinesisVerticle.class.getCanonicalName());
        futures.add(vertx.deployVerticle(KinesisVerticle.class, new DeploymentOptions().setInstances(5)));

        CompositeFuture.all(futures)
                .onSuccess(res -> startFuture.complete())
                .onFailure(err -> {
                    LOGGER.severe(err.getMessage());
                    startFuture.fail(err);
                });
    }