删除所有待处理的 KubeMQ 消息

Question

我有一个使用 KubeMQ 的集成测试设置，有时，当其中一个无法消化在其测试套件中发送的所有消息时，消息可以进入下一个测试并使它们失败。我想知道是否有办法在不终止 KubeMQ 连接的情况下强制 KubeMQ 删除所有存储的消息。该应用程序在 Go 中，如果您有任何github.com/kubemq-io/kubemq-go特定的解决方案，它会更好（我无法在包中找到任何有用的东西）。

Answer 1

您可以使用 AckAll 命令清除队列中的所有消息。利奥，