1

我正在使用 java 和 rabittmq 进行 RPC 实现。

我希望能够通过超时停止消费者,这意味着在消费者处理的超时结束后,我希望消息向客户端发送响应消息以通知消费者无法处理请求.

例如,如果我的消费者由于某种原因挂起,那么超时将通知并向客户端发送错误消息。

4

0 回答 0