Bean public MqttClient mqttClient MqttClient mqttClient = new MqttClientmqttPropertyConfiggetBroker MqttClientgenerateClientId; MqttConnectOptions mqttConnectOptions = new Mq

@Bean public Mono mqttClient() { return Mono.fromCallable(() -> { MqttClient mqttClient = new MqttClient(mqttPropertyConfig.getBroker(), MqttClient.generateClientId()); MqttConnectOptions mqttConnectOptions = new MqttConnectOptions(); mqttConnectOptions.setAutomaticReconnect(true); mqttConnectOptions.setUserName(mqttPropertyConfig.getUsername()); mqttConnectOptions.setPassword(mqttPropertyConfig.getPassword().toCharArray()); mqttClient.connect(mqttConnectOptions); return mqttClient; });