我们如何使用 JMS 消息存储处理存储和转发答案

【问题标题】：How we can process the Store and Forward Using JMS Message Stores我们如何使用 JMS 消息存储处理存储和转发
【发布时间】：2013-08-15 03:18:44
【问题描述】：

我已经完成了axis2文件中的所有更改并将jar文件放到lib中我的消息处理工作正常并且还存储当我向包含存储调解器和定义的 target.endpoint 的代理发送请求时，也在请求消息存储在消息存储中之后它不处理我的配置文件

<proxy xmlns="http://ws.apache.org/ns/synapse" name="Message" transports="https,http" statistics="disable" trace="disable" startOnLoad="true">
   <target>
      <inSequence>
         <log level="full"/>
         <property name="faisal" value="faisal" scope="default" type="STRING"/>
         <property name="target.endpoint" value="JmsChecking" scope="default" type="STRING"/>
         <store messageStore="faisal5"/>
      </inSequence>
      <outSequence>
         <log level="full"/>
      </outSequence>
   </target>
   <description></description>
</proxy

消息存储是

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

和消息处理器

<messageProcessor name="faisal" class="org.apache.synapse.message.processors.forward.ScheduledMessageForwardingProcessor" messageStore="faisal5" xmlns="http://ws.apache.org/ns/synapse">
   <parameter name="interval">1000</parameter>
   <parameter name="max.delivery.attempts">4</parameter>
</messageProcessor>

和端点定义是这样的及其条目

<endpoint xmlns="http://ws.apache.org/ns/synapse" name="JmsChecking">
   <address uri="http://localhost:8282/services/JmscheckingEndpoint" format="soap11">
      <suspendOnFailure>
         <progressionFactor>1.0</progressionFactor>
      </suspendOnFailure>
      <markForSuspension>
         <retriesBeforeSuspension>0</retriesBeforeSuspension>
         <retryDelay>0</retryDelay>
      </markForSuspension>
   </address>
</endpoint>

端点包含日志值代理

proxy xmlns="http://ws.apache.org/ns/synapse" name="JmscheckingEndpoint" transports="https,http" statistics="disable" trace="disable" startOnLoad="true">
   <target>
      <inSequence>
         <log level="custom">
            <property name="Message" value="JMs working fine"/>
            <property name="value" expression="//mail/text()"/>
         </log>
      </inSequence>
      <outSequence>
         <send/>
      </outSequence>
   </target>
   <description></description>
</proxy>

现在我正在发送我的请求这个日志值是这样打印的

[2013-07-25 11:42:03,039]  INFO - LogMediator Message = JMs working fine, value = faisal.shaik@youtility.in
[2013-07-25 11:42:03,039]  INFO - LogMediator Message = JMs working fine, value = faisal.shaik@youtility.in
[2013-07-25 11:42:03,039]  INFO - LogMediator Message = JMs working fine, value = faisal.shaik@youtility.in
[2013-07-25 11:42:03,039]  INFO - LogMediator Message = JMs working fine, value = faisal.shaik@youtility.in

以及消息进程正在停用。如果我再发送一个请求，它只是存储其未处理的消息进程 bcoz 处于停用状态这个 JMS 只能这样工作我的情况是，如果端点可用，我将收到请求，如果端点不可用，消息也将传递和删除，即使端点不可用，消息也会重试最大提及次数，然后它将存储在消息存储中这个参数有什么用，请您解释一下我关注了这个链接http://docs.wso2.org/wiki/display/ESB460/Store+and+Forward+Using+JMS+Message+Stores 我在哪里可以找到这个 faisal5_Queue 存储点是否作为文件夹存在

   <parameter name="store.jms.destination">faisal5_Queue</parameter>

【问题讨论】：

标签： wso2 wso2esb

【解决方案1】：

不，它不会创建文件夹。当您提到“store.jms.destination”时使用 faisal5_Queue wso2 esb 将在您的消息代理（在您的情况下为 ActiveMQ）中使用您指定的名称“faisal5_Queue”创建一个队列。如果您没有明确提及，WSO2 esb 将使用“YourMessageStoreName_Queue”创建一个队列

您可以进一步参考这些博客以了解“消息存储”和“消息处理器”的行为

http://vanjikumaran.blogspot.com/2013/08/jms-store-and-jms-processor-behavior.html http://vanjikumaran.blogspot.com/2013/08/jms-messagenstore-and-jms-message.html http://vanjikumaran.blogspot.com/2013/08/jms-messagen-store-and-jms-message.html

【讨论】：