用于使用REST API存储和转发的WSO2 ESB故障序列

Question

目前，我们在WSO2 ESB中使用Store and Forward模式。因此，当消息进入代理时，我们使用序列将其移入存储（队列），然后使用消息处理器处理排队的消息并将其发送到REST API，即异步处理消息。然而，当REST API抛出400、404、409或422时，处理器停止（对于50x错误相同）。我们希望将这些4xx状态代码的失败消息移到一个单独的队列中，在那里可以对它们进行诊断和处理。这意味着，如果有一个坏消息，它不会停止处理其余的队列消息。我们只想对4xx故障这样做。5xx或网络问题/超时应继续停止处理器。我研究了死信通道(https://docs.wso2.com/display/integrationpatterns/Dead+Letter+Channel)，但这似乎只与代理（同步请求）兼容。因此，我尝试使用一个故障序列将消息移动到另一个队列，然而，该故障序列似乎只适用于SOAP故障。是否有可能使它与REST API状态代码错误一起工作？https://docs.wso2.com/display/esb481/error+处理

我注意到可以添加状态代码，但这似乎只对减少重试尝试有用。提前道谢。

跟进

<?xml version="1.0" encoding="UTF-8"?>
<proxy xmlns="http://ws.apache.org/ns/synapse"
   name="TestProxy"
   transports="https,http"
   statistics="disable"
   trace="disable"
   startOnLoad="true">
<target faultSequence="DeadLetterQueueSequence">
  <inSequence>
     <log level="custom" category="ERROR">
        <property name="TEST" value="Proxy was hit"/>
     </log>
  </inSequence>
  <endpoint>
     <address uri="http://localhost:8080/sampleService/failEndpoint400"/>
  </endpoint>
</target>
<description/>
</proxy>

第二步：添加死信序列：

<sequence xmlns="http://ws.apache.org/ns/synapse" name="DeadLetterQueueSequence" trace="disable">
<log level="full" category="ERROR">
  <property name="Test" value="DeadLetterQueueSequence was hit"></property>
</log>
</sequence>

出现第1个日志条目，但不会出现第2个日志条目（来自死信序列）。

WSO2 ESB似乎不是REST友好的，只能很好地与SOAP服务配合使用。

Answer 1

在您的消息处理器conf（forwardnig）中，您可以将消息从存储区直接发送到REST API，而不是直接将消息从存储区发送到ESB内部的代理服务，在它的outSequence中，您可以测试状态代码、响应内容等，并最终决定将消息移动到另一个存储区。

在此outSequence中,您可以选择使用状态代码来响应您的消息处理器：

• 200或500：将执行回复序列（并将从存储区中删除消息）
• 任何其他状态代码：将执行faul序列（并且消息将保留在sotre中）