mqtt 发送消息断开链接

Question

出现如下错误

o.s.i.mqtt.outbound.MqttPahoMessageHandler|Lost connection; will attempt reconnect on next request

我的配置

    @Bean
    public MqttPahoClientFactory mqttClientFactory1() {
        DefaultMqttPahoClientFactory factory = new DefaultMqttPahoClientFactory();

        MqttConnectOptions options = new MqttConnectOptions();
        options.setUserName(mqttConfig.getOutbound().getUsername());
        options.setPassword(mqttConfig.getOutbound().getPassword().toCharArray());
        options.setServerURIs(mqttConfig.getOutbound().getUrls().split(","));
/*        options.setConnectionTimeout(mqttConfig.getOptions().getConnectionTimeout());
        options.setKeepAliveInterval(mqttConfig.getOptions().getKeepAliveInterval());
        options.setMaxInflight((Runtime.getRuntime().availableProcessors() * 2) * 6);
        options.setCleanSession(false);
        options.setAutomaticReconnect(true);*/

        factory.setConnectionOptions(options);
        return factory;
    }

    @Bean
    @ServiceActivator(inputChannel = "mqttOutboundChannel")
    public MessageHandler mqttOutbound() {
        MqttPahoMessageHandler messageHandler =
                new MqttPahoMessageHandler(mqttConfig.getOutbound().getClientId(), mqttClientFactory1());
        messageHandler.setAsync(true);
        return messageHandler;
    }

    @Bean
    public MessageChannel mqttOutboundChannel() {
        return new DirectChannel();
    }