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