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);
});
}