private void fillCacheWithData()

in services/tracking-service/reactive-vertx/src/main/java/com/amazon/verticles/HttpVerticle.java [79:99]


    private void fillCacheWithData(final RoutingContext routingContext) {
        LOGGER.info("Filling caches with data ... ");
        LOGGER.fine("Reading JSON-data");

        FileSystem fs = vertx.fileSystem();
        fs.readFile("META-INF/data.json")
                .onSuccess(buf -> {
                    JsonArray jsonArray = buf.toJsonArray();
                    for (Object aJsonArray : jsonArray) {
                        JsonObject obj = (JsonObject) aJsonArray;
                        LOGGER.fine("Sending message to cache-verticles: " + obj);
                        eb.send(Constants.CACHE_STORE_EVENTBUS_ADDRESS, obj);
                        eb.send(Constants.REDIS_STORE_EVENTBUS_ADDRESS, obj);
                    }
                    routingContext.end();
                })
                .onFailure(err -> {
                    LOGGER.info(err.getMessage());
                    routingContext.fail(err);
                });
    }