可以使用flatMap()方法将Mono转换为Mono, 然后使用subscribe()方法来获取MqttClient对象。示例代码如下:

@Autowired private Mono mqttClientMono;

public void doSomething() { mqttClientMono.flatMap(mqttClient -> { // 在这里使用MqttClient对象 return Mono.just(mqttClient); }).subscribe(); }

在上面的示例代码中,首先注入了一个Mono对象,然后在doSomething()方法中,使用flatMap()方法将Mono转换为Mono, 然后在flatMap()方法中使用MqttClient对象进行具体的操作。最后使用subscribe()方法来订阅Mono

Beanpublic MonoMqttClient mqttClient return MonofromCallable - MqttClient mqttClient = new MqttClientmqttPropertyConfiggetBroker MqttClientgenerateClientId; MqttConnectOptions mqttC

原文地址: https://www.cveoy.top/t/topic/fh2W 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录