Spring MQTT訂閱者配置

Question

我試圖通過Spring MQTT客戶端閱讀訂閱的主題消息。

<mqtt:message-driven-channel-adapter id="mqttInbound" 
    client-id="mySpringServer" 
    url="tcp://localhost:1883" 
    topics="foo2015" 
    auto-startup="true" 
    client-factory="clientFactory" 
    channel="fileChannel"/> 

比具有 「fileChannel」 信道相反，我喜歡通過Spring MQTT客戶端來處理它們。 例如：MqttPahoMessageDrivenChannelAdapter

我可以使用MqttPahoMessageDrivenChannelAdapter作爲一個bean，並參照 「mqttInbound」？

所有傳入「mqttInbound」的消息都會重定向到MqttPahoMessageDrivenChannelAdapter。我可以這樣做嗎？

更新： 我可以將傳入消息重定向到bean嗎？有沒有我可以使用的界面？

例如：

<mqtt:message-driven-channel-adapter ... channel="msgChannel" /> 
<bean id="msgChannel" class="org.channel.AnyMessageReader"/> 

我看到下面的例子，但我不知道究竟這就是我要找的。

<int:channel id="channel_01" /> 
<int:service-activator id="serviceActivator" input-channel="channel_01" ref="msgService" method="setMessage" /> 
<bean id="msgService" class="org.channel.AnyMessageService"/> 

Answer 1

對不起，或者你誤解了Spring Integration，或者我錯過了你的任何問題。

的<mqtt:message-driven-channel-adapter>是用於MqttPahoMessageDrivenChannelAdapter的高級別組件：

1. MqttNamespaceHandler

   this.registerBeanDefinitionParser("message-driven-channel-adapter", new MqttMessageDrivenChannelAdapterParser()); 
   

2. MqttMessageDrivenChannelAdapterParser

    BeanDefinitionBuilder builder = BeanDefinitionBuilder 
          .genericBeanDefinition(MqttPahoMessageDrivenChannelAdapter.class); 
   

那麼，將MqttPahoMessageDrivenChannelAdapter換成MqttPahoMessageDrivenChannelAdapter有什麼意義？

你有一些擴展嗎？因此，您必須聲明自定義的常規<bean>，但MessageProducer的outputChannel仍然是必需的。