清空所有未处理的 KubeMQ 消息

大家好，今天本人给大家带来文章《清空所有未处理的 KubeMQ 消息》，文中内容主要涉及到，如果你对Golang方面的知识点感兴趣，那就请各位朋友继续看下去吧~希望能真正帮到你们，谢谢！

我设置了一个使用 KubeMQ 的集成测试，有时，当其中一个测试无法消化其测试套件中发送的所有消息时，这些消息可能会进入下一个测试并导致测试失败。

我想知道是否有办法强制 KubeMQ 删除所有存储的消息而不终止 KubeMQ 连接。该应用程序是用 Go 编写的，如果您有任何 github.com/kubemq-io/kubemq-go 特定解决方案，那就更好了（我在包中找不到任何有用的东西）。

正确答案

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

到这里，我们也就讲完了《清空所有未处理的 KubeMQ 消息》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于的知识点！