我正在运行一个spring云流应用程序,使用来自rabbitmq的消息。我想实现一种行为,在这种行为中,一个给定的队列(有三个使用者示例)只向其中任何一个传递一条消息,然后等待下一条消息被传递,直到确认当前消息为止(所有使用者之间的某种同步)。我认为这可以用这个来完成https://www.rabbitmq.com/consumer-prefetch.html 启用了全局选项,但我找不到使用springcloudstream实现这一点的方法。任何帮助都将不胜感激。
7hiiyaii1#
spring为每个消费者使用一个单独的通道,因此全局通道预取不会产生任何影响。请记住,即使它得到支持,也只有当消费者都在同一个示例中时,它才会起作用。
1条答案
按热度按时间7hiiyaii1#
spring为每个消费者使用一个单独的通道,因此全局通道预取不会产生任何影响。
请记住,即使它得到支持,也只有当消费者都在同一个示例中时,它才会起作用。