code: protected void reconnect(Throwable cause) {
  		if (cause != null) {
  			String msg = cause.getMessage();
  			if (msg == null || msg.isEmpty()) {
  				msg = "Unable to connect to JMS server!";
  			} else if (!msg.endsWith("!") && !msg.endsWith(".")) {
  				msg += "!";
  			}
  			logger.warn(msg);
  		}
  		disconnect();
  		logger.info("Trying to reconnect...");
  		scheduler.schedule(this::connect, 5, TimeUnit.SECONDS);
  	}
docs: --- RECONNECT ---