2013-08-20 90 views
0

我使用wso2esb4.7.0和ActiveMQ的 5.8.0版本,我也跟着wso2esb文檔他們提供的存儲和轉發郵件存儲政策 但我不想店消費的消息,我只是想消費的消息,這些消息已經有我的客戶端應用程序一直商店 我希望彙集,每5秒 信息是否有可能在使用ActiveMQ的 wso2esb JMS將你寫代理的示例代碼我們能否使用wso2esb的Jms

<messageProcessor name="Duplicate5" class="org.apache.synapse.message.processors.forward.ScheduledMessageForwardingProcessor" messageStore="Duplicate" xmlns="http://ws.apache.org/ns/synapse"> 
    <parameter name="interval">1000</parameter> 
    <parameter name="message.processor.reply.sequence">fault</parameter> 
</messageProcessor> 

我試着用這一點,但它的不工作

回答

0

要從隊列中提取消息,您需要使用JMS transport..Check JMS代理來處理這些示例。

0

消息存儲以可序列化Java對象的形式持久存儲消息。這可能包含某些在ActiveMQ控制檯中查看消息詳細信息時在消息中不可見的基本信息(例如:屬性)。消息處理器在處理消息時使用存儲器存儲的這些信息。因此,據我所知,如果你想讓事情發揮作用,消息存儲和消息處理器應該一起使用。

如果您直接將收到的消息存儲在ActiveMQ隊列中,則可能必須手動配置消息使用者。檢查這個用例[1]。

也看看這個博客帖子的例子得到一個想法[2]。

[1] http://docs.wso2.org/wiki/display/ESB470/ESB+as+a+JMS+Consumer

[2] http://nuwanwimalasekara.blogspot.com/2013/04/jms-proxy-service-using-wso2-esb.html

希望這有助於。