code: @Override
  	public void connected(MqttClient client, ConnectReturnCode returnCode) {
  		logger.info("MQTT pub-sub connection estabilished.");
  		scheduler.schedule(this::connected, 100, TimeUnit.MILLISECONDS);
  	}
docs: --- CONNECTED ---