如何解决避免向/从 RabbitMQ 发布/使用重复消息
我的要求是如果条件不满足,消费者不消费消息,将消费的消息发布回rabbitmq并停止Masstransit总线(我相信消费者无法停止)。我可以将消耗的消息发布回rabbitmq并停止总线但问题是,一旦我发布消息,我的消费者在停止总线之前再次消耗相同的消息并再次发布相同的消息并且它重复直到总线停止。结果,我在队列中收到了重复的消息。
if(!valid)
{
await ep.Send(message);
bus.StopAsync();
}
我认为在这种情况下启用rabbitmq_message_deduplication 插件可能会有所帮助,但只是想知道是否还有其他方法可以实现。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。