带有 RabbitMQ 的 WSO2 EI - 如何拒绝消息？

Question

使用 WSO2EI 6.4.0 和 RabbitMQ 作为入站传输，如文档 RabbitMQ AMQP Transport 中所述。

似乎运行良好，但只涵盖了 "sunny day" 场景。

需要保留消息顺序，在异常情况下我们不能只是将消息重新排队回队列。如果后端服务不可用，我想回滚消息并尝试稍后处理消息。据我了解，我们需要发送 nack 响应。

<?xml version="1.0" encoding="UTF-8"?>
<proxy xmlns="http://ws.apache.org/ns/synapse"
       name="test_mgs_processing_proxy"
       startOnLoad="true"
       statistics="disable"
       trace="disable"
       transports="http,rabbitmq,local">
   <target>
      <inSequence>
         <log level="full">
            <property name="step" value="test_mgs_processing_proxy"/>
         </log>
         <property name="OUT_ONLY" value="true"/>
         <!-- simulate an exception has occured -->
         <property name="SET_ROLLBACK_ONLY" scope="axis2" value="true"/>
         <payloadFactory media-type="xml">
            <format>
               <step xmlns="">test_mgs_processing_proxy</step>
            </format>
            <args/>
         </payloadFactory>
      </inSequence>
   </target>
   <parameter name="rabbitmq.exchange.name">amq.topic</parameter>
   <parameter name="rabbitmq.queue.name">app_a</parameter>
   <parameter name="rabbitmq.connection.factory">AMQPConnectionFactory</parameter>
   <description/>
</proxy>

设置FORCE_SC_ACCEPTED 使消息被视为已消耗。即使我们设置了SET_ROLLBACK_ONLY属性，消息也停留在NACK状态，不会重发（至少不会很快）。

问题 - 使用 RabbitMQ AMQP 传输，有没有办法配置未处理消息的重新传递间隔？

Answer 1

这似乎是 WSO2 EI 6.4.0 中的一个问题。 https://github.com/wso2/product-ei/issues/4739

当您使用入站终结点时，问题不存在。仅当您将代理与 rabbitmq 传输一起使用时才会出现此问题。

带有 RabbitMQ 的 WSO2 EI - 如何拒绝消息？

WSO2 EI with RabbitMQ - how to reject a message?

wso2

rabbitmq