带有 AMQP 连接器的 rabbitmq 的 akka 流消费者答案

【问题标题】：akka stream consumer of rabbitmq with AMQP connector带有 AMQP 连接器的 rabbitmq 的 akka 流消费者
【发布时间】：2017-05-30 05:46:37
【问题描述】：

我想使用akka stream (Java) 使用来自rabbitMQ 队列的数据。我从以下链接获得帮助：http://developer.lightbend.com/docs/alpakka/latest/amqp.html

我想知道元素被消费后到rabbitMQ 的确认流程。

我可以并行使用元素吗？（Java sn-p 会很有帮助）

谢谢

【问题讨论】：

你能澄清一下吗？您是否正在寻找致谢文档未提供的特定内容？
我想用akka流消费rabbitmq。我发现带有amqp连接器的akka流，首先从队列中弹出元素，向队列发送确认，然后将元素发送到下游（akka流）消费。
我希望这个确认在我的控制之下。这可能吗？
听起来你可能需要选择另一个 RabbitMQ 客户端，如果这个“akka”工具不能做你想让它做的事情。您当然可以选择使用 AMQP/RMQ 对确认进行精细控制。

【解决方案1】：

当前的 Alpakka AMQP 连接器会在消息发出后立即对消息进行天真确认，有一个工单跟踪添加了一个更灵活的解决方案，您可以在此处遵循：https://github.com/akka/alpakka/issues/97

【讨论】：