我希望能够选择性地从AMQP队列中删除消息,而不必读取它们。
场景如下:
发送方想基于X类型的新信息到达这一事实过期X类型的消息。因为订阅者很可能还没有消费最新的X类型消息,所以发布者应该只删除之前的X类型消息,然后将最新的消息放入队列中。整个操作对订阅者应该是透明的 - 实际上,他应该使用诸如STOMP之类的简单方法来获取消息。
如何使用AMQP实现?或者在另一种消息传递协议中更方便?
我想避免复杂的基础设施。所需的整个消息传递过程就像上面那样简单:一个队列,一个订阅者,一个发布者,但是发布者必须具有根据给定条件临时删除消息的能力。
发布者客户端将使用Ruby,但实际上只要我发现如何在协议中完成此操作,我会处理任何语言。