Eclipse的泛美卫生组织MQTT - 的Spring Java配置

Question

我想在我的项目用SpringMVC使用MQTT。官方示例，In this link用new关键字创建所有对象。据我所知，这不是Spring风格。建议创建bean的方法不是吗？

我发现了一些例子（弹簧集成，MQTT，其基于Eclipse的泛美卫生组织，MQTT）配置的基于XML的，但我想让它基于Java的配置。我完成了基于Java的整个项目。项目中没有.xml文件（甚至不包括web.xml）。

如果你建议我用Java的配置或有关XML的配置转换为Java的配置，我将appriciated好的文件的例子。

在此先感谢。

Answer 1

您可以跟踪对此事Pull Request，但让我分享一段代码在这里追踪的详细信息，以及：

@Bean 
public MessageProducer inbound() { 
    MqttPahoMessageDrivenChannelAdapter adapter = 
      new MqttPahoMessageDrivenChannelAdapter("tcp://localhost:1883", "testClient", 
              "topic1", "topic2"); 
    adapter.setCompletionTimeout(5000); 
    adapter.setConverter(new DefaultPahoMessageConverter()); 
    adapter.setQos(1); 
    adapter.setOutputChannel(mqttInputChannel()); 
    return adapter; 
} 

@Bean 
@ServiceActivator(inputChannel = "mqttOutboundChannel") 
public MessageHandler amqpOutbound() { 
    MqttPahoMessageHandler messageHandler = 
        new MqttPahoMessageHandler("testClient", mqttClientFactory()); 
    messageHandler.setAsync(true); 
    messageHandler.setDefaultTopic("testTopic"); 
    return messageHandler; 
}