删除所有待处理的 KubeMQ 消息

我有一个使用 KubeMQ 的集成测试设置，有时，当其中一个无法消化在其测试套件中发送的所有消息时，消息可以进入下一个测试并使它们失败。

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