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
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
