我正在尝试将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&java.naming.factory.initial=org.wso2.andes.jndi.PropertiesFileInitialContextFactory&java.naming.provider.url=repository/conf/jndi.properties&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服务器示例),但问题是当我关闭服务器时,消息会在主题队列中累积,当我再次启动服务器时,订阅服务器不会使用也不会将累积的消息发送到服务器,我想知道什么时候使用带有java代码的wso2mb无wso2esb和JMS客户端订阅服务器,持久的主题能够很好地工作,并在启动服务器后使用消息。有什么想法吗?
发布于 2016-07-05 07:14:22
使用此链接解决了中介序列和错误序列的问题
https://stackoverflow.com/questions/37905685
复制相似问题