我正在尝试编写能够抵抗意外情况的 MQ 客户端。我用 client_acknowledge 模式创建了客户端:
ISession session = conn.CreateSession(false, AcknowledgeMode.ClientAcknowledge);
在 XMS 文档中有 CLIENT_ACKNOWLEDGE 的信息:
应用程序可以单独确认收到每条消息,也可以接收一批消息并仅针对它收到的最后一条消息调用 Acknowledge 方法。当调用 Acknowledge 方法时,自上次调用该方法以来收到的所有消息都会被确认。
客户端从队列中获取例如 10 条消息并将它们写入数据库。
问题是如何设置此模式并确认每条消息(以确保消息传递)?