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流)以供使用。 –
我希望得到我的支持。這可能嗎? –