删除所有待处理的KubeMQ消息。

huangapple go评论86阅读模式
英文:

Delete all the pending KubeMQ messages

问题

我有一个使用KubeMQ的集成测试设置,有时,当其中一个测试无法处理其测试套件中发送的所有消息时,消息可能会传递到下一个测试并导致它们失败。

我想知道是否有一种方法可以强制KubeMQ丢弃所有存储的消息而不中断KubeMQ连接。应用程序使用Go语言编写,如果您有任何github.com/kubemq-io/kubemq-go的特定解决方案,那就更好了(我在该包中没有找到有用的内容)。

英文:

I have an integration tests set up which use KubeMQ, and sometimes, when one of them fails to digest all the messages sent in it's test suite the messages can get to the next test and make them fail.

I wan't to know if is there a way to force KubeMQ to drop all the stored messages without killing the KubeMQ connection. The application is in Go and if you have any github.com/kubemq-io/kubemq-go specific solution it would be even better(I was not able to find anything useful in the package).

答案1

得分: 1

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

英文:

You can use the AckAll command that will purge all the messages in the queue.
Lior,

huangapple
  • 本文由 发表于 2022年11月17日 16:28:16
  • 转载请务必保留本文链接:https://go.coder-hub.com/74472262.html
匿名

发表评论

匿名网友

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen:

确定