Spring Cloud Data Flow 可编程应用程序的错误通道
Spring Cloud Data Flow programmable application's error channel
如何定义或编程应用程序的错误通道,以接收在 processors/sinks 中失败的所有消息?
文档说明如下:
When the number of retry attempts has exceeded the maxAttempts value, the exception and the failed message will become the payload of a message and be sent to the application’s error channel. By default, the default message handler for this error channel logs the message. You can change the default behavior in your application by creating your own message handler that subscribes to the error channel.
在那之后,文档讨论了在活页夹中启用死信队列。如果我理解正确,整个概念意味着我可以编写自己的处理程序来订阅活页夹的 DLQ 并接收消息。
我很好奇,是否可以定义一个单独的流来接收失败的消息,或者编写一个额外的应用程序来接收那些失败的有效负载并按照需要的方式处理它们而不使用活页夹的 DLQ?
假设您已经启用了 DLQ,并且根据所使用的活页夹实现,您可能必须创建一个单独的应用程序来从 DLQ 中提取和处理消息。
例如,rabbit-binder 的推荐方法可以在 docs 中找到。
如何定义或编程应用程序的错误通道,以接收在 processors/sinks 中失败的所有消息?
文档说明如下:
When the number of retry attempts has exceeded the maxAttempts value, the exception and the failed message will become the payload of a message and be sent to the application’s error channel. By default, the default message handler for this error channel logs the message. You can change the default behavior in your application by creating your own message handler that subscribes to the error channel.
在那之后,文档讨论了在活页夹中启用死信队列。如果我理解正确,整个概念意味着我可以编写自己的处理程序来订阅活页夹的 DLQ 并接收消息。
我很好奇,是否可以定义一个单独的流来接收失败的消息,或者编写一个额外的应用程序来接收那些失败的有效负载并按照需要的方式处理它们而不使用活页夹的 DLQ?
假设您已经启用了 DLQ,并且根据所使用的活页夹实现,您可能必须创建一个单独的应用程序来从 DLQ 中提取和处理消息。
例如,rabbit-binder 的推荐方法可以在 docs 中找到。