如何从文件中读取数据并将其存储在WSO2中的消息存储库中

Question

任何人都可以建议我如何从一个文件中读取数据并将其添加到消息存储库。

我正在尝试在ESB中开发消息重发功能。

想法：

消息从一个代理服务转到目标点

将消息保存在不同的文件中（每个文件一条消息）。

编写另一个代理服务，该服务将从文件夹中的所有文件中读取内容并将其放入消息存储库中。

现在处理器将位于商店的顶部，将从商店发送消息到目的地点。

关心马赫什

Answer 1

ActiveMQ中的消息存储“MyStore”：

<messageStore xmlns="http://ws.apache.org/ns/synapse" class="org.wso2.carbon.message.store.persistence.jms.JMSMessageStore" name="MyStore">
    <parameter name="java.naming.factory.initial">org.apache.activemq.jndi.ActiveMQInitialContextFactory</parameter>
    <parameter name="store.jms.cache.connection">false</parameter>
    <parameter name="java.naming.provider.url">failover:tcp://localhost:61616</parameter>
    <parameter name="store.jms.JMSSpecVersion">1.1</parameter>
</messageStore>

消息处理器：从存储中读取并向端点“MyEPR”发送消息

<messageProcessor xmlns="http://ws.apache.org/ns/synapse" class="org.apache.synapse.message.processor.impl.forwarder.ScheduledMessageForwardingProcessor" name="MyStoreForwarder" targetEndpoint="MyEPR" messageStore="MyStore">
    <parameter name="message.processor.reply.sequence">MyReplySequence</parameter>
    <parameter name="max.delivery.attempts">-1</parameter>
    <parameter name="client.retry.interval">5000</parameter>
    <parameter name="interval">10</parameter>
    <parameter name="message.processor.fault.sequence">MyFaultSequence</parameter>
    <parameter name="is.active">true</parameter>
</messageProcessor>

代理服务：读取file：/// home / test中的xml文件并将它们存储到“MyStore”中

<proxy xmlns="http://ws.apache.org/ns/synapse" name="MyProxy" transports="vfs" statistics="disable" trace="disable" startOnLoad="true">
   <target>
    <inSequence>
      <store messageStore="MyStore"/>
    </inSequence>
   </target>
   <parameter name="transport.PollInterval">15</parameter>
   <parameter name="transport.vfs.FileURI">file:///home/test</parameter>
   <parameter name="transport.vfs.FileNamePattern">.*.xml</parameter>
   <parameter name="transport.vfs.ContentType">application/xml; charset=ISO-8859-1</parameter>
</proxy>

Answer 2

此问题是由于未在axis2.xml配置中启用vfs传输发送方。