0

我正在尝试将 wso2mb 与 wso2esb 集成，并在订阅者不活动时使用持久主题将消息保留在队列中并在将来恢复它们。我在 wso2mb 文档中使用了第一种集成方法（使用 JMS 端点和 JMS 代理服务集成）。这是我的发布者代理：

<?xml version="1.0" encoding="UTF-8"?>
<proxy xmlns="http://ws.apache.org/ns/synapse"
   name="InTopicProxy"
   transports="https,http"
   statistics="disable"
   trace="disable"
   startOnLoad="true">
  <target>
  <inSequence>
     <property name="OUT_ONLY" value="true"/>
     <property name="FORCE_SC_ACCEPTED" value="true" scope="axis2"/>
     <send>
        <endpoint>
           <address uri="jms:/MyDurbleTopic?transport.jms.ConnectionFactoryJNDIName=QueueConnectionFactory&amp;java.naming.factory.initial=org.wso2.andes.jndi.PropertiesFileInitialContextFactory&amp;java.naming.provider.url=repository/conf/jndi.properties&amp;transport.jms.DestinationType=topic"/>
        </endpoint>
     </send>
  </inSequence>
  </target>
  <description/>
  </proxy>\

我使用这个答案来创建消费者代理和持久主题，这是我的订阅者代理：

<?xml version="1.0" encoding="UTF-8"?>
<proxy xmlns="http://ws.apache.org/ns/synapse"
   name="TopicSubProxy"
   transports="jms"
   statistics="disable"
   trace="disable"
   startOnLoad="true">
   <target>
  <inSequence>
     <property name="OUT_ONLY" value="true"/>
     <log level="custom">
        <property name="STATE" value="dispatch message..."/>
     </log>
     <send>
        <endpoint>
           <address uri="http://localhost:9000/services/SimpleStockQuoteService"/>
        </endpoint>
     </send>
  </inSequence>
  <outSequence>
     <send/>
  </outSequence>
  </target>
  <parameter name="transport.jms.ContentType">
  <rules>
     <jmsProperty>contentType</jmsProperty>
     <default>text/xml</default>
  </rules>
  </parameter>
    <parameter name="transport.jms.ConnectionFactory">myTopicConnectionFactory</parameter>
   <parameter name="transport.jms.DestinationType">topic</parameter>
   <parameter name="transport.jms.SubscriptionDurable">true</parameter>
   <parameter name="transport.jms.Destination">MyDurbleTopic</parameter>
   <parameter name="transport.jms.DurableSubscriberName">subId-x</parameter>
   <parameter name="transport.jms.CacheLevel">consumer</parameter>
   <parameter name="transport.jms.DurableSubscriberClientID">subId-x</parameter>
   <description/>
</proxy>

我可以使用 SoapUI 调用发布者代理，订阅者代理将使用消息并将它们发送到 SimpleStockQuoteService（wso2esb 服务器示例），但问题是当我关闭服务器时，消息会累积在主题队列中，当我再次启动服务器时，订阅者不消费也不向服务器发送累积的消息，我想知道当我使用没有 wso2esb 的 wso2mb 和带有 java 代码的 JMS 客户端订阅者时，持久主题完美地工作并在启动服务器后消费消息。有任何想法吗？

4

1 回答 1

0

使用此链接通过调解序列和错误序列解决了问题

于 2016-07-05T07:14:22.293 回答