出现如下错误

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();

}