0
我想从rabbitMQ
队列中使用数据akka stream
(Java
)。我从以下链接中获得帮助:http://developer.lightbend.com/docs/alpakka/latest/amqp.htmlakka使用AMQP连接器rabbitmq的流消费者
我想知道有关元素消耗后rabbitMQ
的确认流程。
我可以并行使用元素吗? (Java代码将是非常有用的)
感谢
我想从rabbitMQ
队列中使用数据akka stream
(Java
)。我从以下链接中获得帮助:http://developer.lightbend.com/docs/alpakka/latest/amqp.htmlakka使用AMQP连接器rabbitmq的流消费者
我想知道有关元素消耗后rabbitMQ
的确认流程。
我可以并行使用元素吗? (Java代码将是非常有用的)
感谢
目前Alpakka AMQP连接器确实消息天真ACKING只要它们是下游发出,有一票跟踪加入,您可以按照这里更灵活的解决方案:https://github.com/akka/alpakka/issues/97
是的..谢谢... –
请您澄清一下吗?有没有具体的你正在寻找确认文件没有提供? – theMayer
我想用akka流消费rabbitmq。我发现带有amqp连接器的akka流首先从队列中弹出元素,将确认发送到队列,然后将元素发送到下游(akka流)以供使用。 –
我希望得到我的支持。这可能吗? –