code: public Future<Boolean> requestConnectionToBroker() {
          FutureTask futureTask = new FutureTask(new Callable<Boolean>() {
              @Override
              public Boolean call() throws Exception {
                  boolean ok = false;
                  try {
                      getConnection();
                      ok = true;
                  } catch (JMSException e) {
                      LOGGER.warn("Error connecting to JMS", e);
                  }
                  return ok;
              }
          });
          reconnectorService.schedule(futureTask, 0, TimeUnit.SECONDS);
          return futureTask;
      }
docs: Requests that this transports attempts to connect to the broker. Occurs asynchronously from the caller initiation.