gistfile1.txt

  public void start(Future<Void> done) {
    Single<DataGridClient> single = DataGridClient.create(vertx, new DataGridConfiguration()
      .setHost("eventstore-dg-hotrod")
      .setPort(11333));

    single.flatMap(client -> client.<String, String>getCache("users"))
      .flatMap(cache -> cache.clear().andThen(Single.just(cache)))
      .subscribe(
        cache -> {
          this.cache = cache;
          LOGGER.info("User Simulator initialized");
          configure(config());
          vertx.eventBus().<JsonObject>consumer("configuration", m -> configure(m.body().getJsonObject("user-simulator")));
          vertx.eventBus().<Boolean>consumer("user-simulator-toggle", b -> toggle(b.body()));
          done.complete(null);
        },
        err -> {
          LOGGER.error("Unable to initialize the User Simulator");
          done.fail(err);
        }
      );
  }