spring-integration-mqtt MqttPahoMessageHandler 没有getConnection()方法

非常抱歉，我之前的回答有误。在Spring Integration中使用MqttPahoMessageHandler连接MQTT服务器时，可以通过以下方式检查连接是否建立成功：

1. 在MqttPahoMessageHandler的bean定义中，设置一个MqttConnectOptions对象，该对象可以设置连接Mqtt服务器的选项，包括连接超时时间、会话心跳间隔等。

2. 通过MqttPahoClientFactory的getClientInstance()方法获取MqttClient连接对象，然后调用MqttClient.isConnected()方法判断连接状态。

示例代码：

@Autowired
private MqttPahoMessageHandler mqttHandler;

@Autowired
private MqttPahoClientFactory mqttClientFactory;

// 检查连接是否成功建立
MqttClient client = mqttClientFactory.getClientInstance(mqttHandler.getClientId());
boolean isConnected = client.isConnected();
if (!isConnected) {
    // 连接未成功建立，进行相应处理
    ...
}

注意：在检查连接状态时，需要确保MqttPahoMessageHandler已经启动。如果未启动，可以使用Spring的ApplicationListener接口监听ContextRefreshedEvent事件，在事件被触发时进行检查。