我已经在WSO2 ESB 4.7.0中配置了支持事务和CLIENT_ACKNOWLEDGE的Apache ActiveMQ。axis2.xml的配置如下:
<parameter name="transport.jms.SessionTransacted">true</parameter>
<parameter name="transport.jms.SessionAcknowledgement" locked="true">CLIENT_ACKNOWLEDGE</parameter>
我有一个简单的JMS传输通道代理,在该代理中,将JMS队列中的消息传递到jax-rs服务。代理代码如下:
<?xml version="1.0" encoding="UTF-8"?>
<proxy xmlns="http://ws.apache.org/ns/synapse"
name="MediaMoveQueue"
transports="jms"
startOnLoad="true"
trace="enable">
<description/>
<target>
<inSequence>
<property name="messageType" value="application/json" scope="axis2"/>
<property name="ContentType" value="application/json" scope="axis2"/>
<send receive="JmsRollbackSequence">
<endpoint>
<address uri="http://192.168.1.2:9766/RestMediaMove_1.0.0/services/rest_media_move_i_f/restmediamoveif/hello"/>
</endpoint>
</send>
<log level="custom">
<property name="In MediaMoveQueue JMSERROR"
expression="get-property('JMSERROR')"/>
</log>
<switch source="get-property('JMSERROR')">
<case regex="true">
<property name="SET_ROLLBACK_ONLY" value="true" scope="axis2"/>
<log level="custom">
<property name="In MediaMoveQueue Transaction Action"
value="Rollbacked"/>
</log>
</case>
<case regex="false">
<log level="custom">
<property name="In MediaMoveQueue Transaction Action"
value="Committed"/>
</log>
</case>
<default>
<property name="SET_ROLLBACK_ONLY" value="true" scope="axis2"/>
<log level="custom">
<property name="In MediaMoveQueue Transaction Action default"
value="Rollbacked"/>
</log>
</default>
</switch>
</inSequence>
<outSequence>
<log level="full">
<property name="test" value="IN outsequence"/>
</log>
<send/>
</outSequence>
</target>
<parameter name="transport.jms.ContentType">
<rules>
<jmsProperty>contentType</jmsProperty>
<default>application/json</default>
</rules>
</parameter>
</proxy>
JmsRollbackSequence序列接收来自JAX-RS服务的回复,并根据返回的成功或失败,我想回滚JMS事务。但如果我在JmsRollbackSequence中设置property属性,则完全没有效果(在使用下面显示的序列之前,我先尝试了它)。事务永远不会回滚。只有在inSequence中设置属性时,回滚才起作用。以下是JmsRollbackSequence的代码:
<?xml version="1.0" encoding="UTF-8"?>
<sequence xmlns="http://ws.apache.org/ns/synapse" name="JmsRollbackSequence">
<property name="JMSERROR" value="true"/>
<log level="full">
<property name="test" value="IN JmsRollbackSequence"/>
</log>
</sequence>
因此,我尝试在JmsRollbackSequence中设置一个名为JMSERROR的属性,并通过在inSequence中的send mediator之后读取它来回滚inSequence中的事务。但是这也不起作用。在JmsRollbackSequence中设置属性之后,inSequence中的switch case被调用,因此当我读取它时,它总是返回null。
我的问题是:
1)我们可以设置
<property name="SET_ROLLBACK_ONLY" value="true" scope="axis2"/>
在序列中,为什么JmsRollbackSequence无法正常工作?
2)由于中介器应该按顺序被调用,为什么在inSequence中的switch case会在JmsRollbackSequence有机会读取回复和设置JMSERROR属性之前运行?