Hello; Note: Please forgive me if I have mistake in English :)
I would use akka-streams and reactive-rabbitmq to consuming/producing message from/to rabbitmq. In my problem I need a publisher (that in akka-streams would be an ActorProducer) that will be the "Source" of a flow to a "Sink" that publish messages to rabbitmq. Other part of the system (mostly other actors) send messages to the publisher, and their message will go through "Flow" to the sink (publish in rabbitmq). In my problem I need the publisher/source know when messages have been published in the queue. In other world I need a guarantee that the message has been handled by sink. I've read the akka-stream documentation but I can't found any good solution to do this. Is there a standard approch to do it? -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to [email protected]. To post to this group, send email to [email protected]. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
