Hi Reza, There is no acknowledgement support built-in to streams since they model a unidirectional stream and acknowledgements need a backchannel. To add that feature you need a backchannel, which means that the processing stages should be modeled as BidiFlows instead of Flows. That also means that instead of a Sink you have to build a Flow[MyMessages, Ack] instead to model your final consumer.
-Endre On Sun, Apr 12, 2015 at 12:26 PM, Reza Samee <[email protected]> wrote: > 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. > -- >>>>>>>>>> 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.
