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; 
}