wso2mb 持久主题订阅在使用 JMS 端点和 JMS 代理服务的集成中不起作用

Question

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

<?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>\

并且我使用 this answer 创建消费者代理和持久主题这是我的订阅者代理：

<?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 客户端订阅者，持久主题完美运行并在启动后使用消息服务器。有什么想法吗？

Answer 1

使用此 link

解决了调解序列和错误序列的问题

wso2mb 持久主题订阅在使用 JMS 端点和 JMS 代理服务的集成中不起作用

wso2mb durable topic subscription doesn't work in Integration Using JMS Endpoints and JMS Proxy Services

integration

wso2

wso2esb

jms-topic

wso2mb