code: @Override
  	public void disconnected(MqttClient client, Throwable cause, boolean reconnecting) {
  		if (cause != null) {
  			String msg = String.valueOf(cause).toLowerCase();
  			if (!msg.contains("refused")) {
  				logger.info("MQTT pub-sub connection aborted.");
  			}
  			reconnect(cause);
  		}
  	}
docs: --- DISCONNECT ---