我们使用 Quarkus Messaging(带有“smallrye-jms”扩展以连接到 IBM MQ)和转换器将以字符串形式接收的消息转换为 Java 对象。
当在“queue_A”中接收到传入消息时,我们必须在以下两个目的地之一中生成消息:
- “queue_A_error”:如果在转换传入消息时遇到问题。此目标中要生成的新消息是有效负载为 JSON 格式的字符串的消息(包含原始有效负载以及遇到的所有错误的列表)。
- “queue_B”:包含以 JSON 序列化的原始对象的消息
我们如何使用 Quarkus Messaging 实现这个错误处理用例?