Блог

Я работаю над простой интеграцией Wso2 RabbitMQ. Мои входящие конечные точки принимают сообщение и отправляют его в последовательность. Затем последовательность сохраняет сообщение. Другая последовательность сбоев в настоящее время регистрирует ошибку. Я пытаюсь снова отправить сообщение в очередь из последовательности.

SalesOrderQueueInboundEP

 <?xml version="1.0" encoding="UTF-8"?>
<inboundEndpoint name="SalesOrderQueueInboundEP" onError="SalesOrderQueueErrorSeq" protocol="rabbitmq" sequence="SalesOrderQueueProcessSeq" suspend="false" xmlns="http://ws.apache.org/ns/synapse">
    <parameters>
        <parameter name="sequential">true</parameter>
        <parameter name="coordination">true</parameter>
        <parameter name="rabbitmq.connection.factory">AMQPConnectionFactory</parameter>
        <parameter name="rabbitmq.server.host.name">localhost</parameter>
        <parameter name="rabbitmq.server.port">5672</parameter>
        <parameter name="rabbitmq.server.user.name">guest</parameter>
        <parameter name="rabbitmq.server.password">guest</parameter>
        <parameter name="rabbitmq.queue.name">SalesOrderQueue</parameter>
        <parameter name="rabbitmq.exchange.name">amq.direct</parameter>
        <parameter name="rabbitmq.message.content.type">application/xml</parameter>
    </parameters>
</inboundEndpoint>

  

SalesOrderQueueProcessSeq

  <?xml version="1.0" encoding="UTF-8"?>
<sequence name="SalesOrderQueueProcessSeq" trace="disable" xmlns="http://ws.apache.org/ns/synapse">
    <log description="Log payload" level="full"/>
    <property expression="json-eval($)" name="body_json_property" scope="default" type="STRING"/>
    <sequence key="SalesDBSeq"/>
</sequence>


  

SalesOrderQueueErrorSeq

 <?xml version="1.0" encoding="UTF-8"?>
<sequence name="SalesOrderQueueErrorSeq" trace="disable" xmlns="http://ws.apache.org/ns/synapse">
    <log description="Log error details in case of failure" level="full">
        <property name="MESSAGE" value="An unexpected error occurred."/>
        <property expression="$ctx:SYNAPSE_REST_API" name="REST_API"/>
        <property expression="$ctx:ERROR_CODE" name="ERROR_CODE"/>
        <property expression="$ctx:ERROR_MESSAGE" name="ERROR_MESSAGE"/>
        <property expression="$ctx:ERROR_DETAIL" name="ERROR_DETAIL"/>
        <property expression="$ctx:ERROR_EXCEPTION" name="ERROR_EXCEPTION"/>
    </log>
</sequence>

  

@NMRhman,

Я считаю, что вам нужно откатить транзакцию, если сообщения переходят к последовательности ошибок.

Можете ли вы добавить следующее к входящей последовательности?

 <parameter name="rabbitmq.queue.auto.ack">false</parameter>
<parameter name="rabbitmq.queue.auto.delete">false</parameter>
  

Кроме того, добавьте следующее свойство, которое предписывает откат сообщения в последовательности ошибок.

 <property name="SET_ROLLBACK_ONLY" value="true" scope="default" type="STRING"/>
  

Модифицированные последовательности следующим образом.

SalesOrderQueueInboundEP

 <?xml version="1.0" encoding="UTF-8"?>
<inboundEndpoint name="SalesOrderQueueInboundEP" onError="SalesOrderQueueErrorSeq" protocol="rabbitmq" sequence="SalesOrderQueueProcessSeq" suspend="false" xmlns="http://ws.apache.org/ns/synapse">
    <parameters>
        <parameter name="sequential">true</parameter>
        <parameter name="coordination">true</parameter>
        <parameter name="rabbitmq.connection.factory">AMQPConnectionFactory</parameter>
        <parameter name="rabbitmq.server.host.name">localhost</parameter>
        <parameter name="rabbitmq.server.port">5672</parameter>
        <parameter name="rabbitmq.server.user.name">guest</parameter>
        <parameter name="rabbitmq.server.password">guest</parameter>
        <parameter name="rabbitmq.queue.name">SalesOrderQueue</parameter>
        <parameter name="rabbitmq.queue.auto.ack">false</parameter>
        <parameter name="rabbitmq.queue.auto.delete">false</parameter>
        <parameter name="rabbitmq.exchange.name">amq.direct</parameter>
        <parameter name="rabbitmq.message.content.type">application/xml</parameter>
    </parameters>
</inboundEndpoint>
  

SalesOrderQueueErrorSeq

 <?xml version="1.0" encoding="UTF-8"?>
<sequence name="SalesOrderQueueErrorSeq" trace="disable" xmlns="http://ws.apache.org/ns/synapse">
    <log description="Log error details in case of failure" level="full">
        <property name="MESSAGE" value="An unexpected error occurred."/>
        <property expression="$ctx:SYNAPSE_REST_API" name="REST_API"/>
        <property expression="$ctx:ERROR_CODE" name="ERROR_CODE"/>
        <property expression="$ctx:ERROR_MESSAGE" name="ERROR_MESSAGE"/>
        <property expression="$ctx:ERROR_DETAIL" name="ERROR_DETAIL"/>
        <property expression="$ctx:ERROR_EXCEPTION" name="ERROR_EXCEPTION"/>
    </log>
    
   <property name="SET_ROLLBACK_ONLY" value="true" scope="default" type="STRING"/>
   
<drop/>
</sequence>
  

Пожалуйста, попробуйте выше и поделитесь своим отзывом.