WSO2中的JMS使用者事务

Question

我试图将WSO2配置为使用来自ActiveMQ的消息，并在处理过程中引发错误时requeue（通常是当对远程web服务的调用失败时）。

<proxy name="SimpleStockQuoteService" transports="jms" startOnLoad="true">
  <target>
     <inSequence onError="JSMErrorHandling">
        <log level="full"/>
        <send>
           <endpoint>
              <address uri="http://localhost/testapp"/>
           </endpoint>
        </send>
        <log level="full"/>
        <log level="custom">
           <property name="Custom log" value="End In Sequence"/>
        </log>
     </inSequence>
     <outSequence>
        ...
     </outSequence>
  </target>
</proxy>
<sequence name="JSMErrorHandling">
  <log level="custom">
     <property name="Error" value="Error executing sequence"/>
  </log>
  <property name="SET_ROLLBACK_ONLY" value="true" scope="axis2"/>
  <drop/>
</sequence>

Activemq在Axis2.xml中配置，属性transport.jms.SessionTransact设置为true。

当远程URL的格式无效（例如使用错误的协议）时，JMS回滚/重新传递/[重定向到死信]特性可以正常工作。但是，如果我停止远程web服务器，或者使用invlaed服务器名称，则不会请求消息，尽管错误由JMSErrorHandling序列处理。

[2013-06-04 12:17:47,810]  INFO - LogMediator To: , WSAction: urn:mediate, SOAPAction: urn:mediate, MessageID: ID:GCHESNEL764-57101-1370344525419-9:1:1:1:1, Direction: request, Envelope: <?xml ver
[2013-06-04 12:17:47,813]  INFO - LogMediator To: , WSAction: urn:mediate, SOAPAction: urn:mediate, MessageID: ID:GCHESNEL764-57101-1370344525419-9:1:1:1:1, Direction: request, Envelope: <?xml ver
[2013-06-04 12:17:47,814]  INFO - LogMediator Custom log = End In Sequence
[2013-06-04 12:17:48,818]  WARN - ConnectCallback Connection refused or failed for : localhost/127.0.0.1:80
[2013-06-04 12:17:48,821]  WARN - EndpointContext Endpoint : endpoint_413907dd1d4e2370ea0ae277fbfebcaf6504f196a11459bb will be marked SUSPENDED as it failed
[2013-06-04 12:17:48,823]  WARN - EndpointContext Suspending endpoint : endpoint_413907dd1d4e2370ea0ae277fbfebcaf6504f196a11459bb - current suspend duration is : 30000ms - Next retry after : Tue J
[2013-06-04 12:17:48,824]  INFO - LogMediator Error = Error executing sequence

最后，如果WSO2服务在处理期间关闭，则不会请求该消息。是否有其他配置可以替代这里提出的配置:http://docs.wso2.org/wiki/display/esb460/jms+faq#jmsfaq-howtopreventmessageLossduetounavailabilityofadataSource

纪尧姆

Answer 1

使用已经在wso2 ESB中实现的Messagestore和MessageProcessor，您可以使用存储和处理技术实现给定的场景！更多的信息可以在保证传递文章[1]、用于DCL的EIP文章[2]、消息转发procssor[3]中找到

[1]http://wso2.com/library/articles/2014/01/probured-delivery-with-message-store-message-processor%20/

[2]http://docs.wso2.org/display/integrationpatterns/dead+letter+channel