Hi, I see in the docs for 2.5.2 that ActorPublisher/ActorSubscriber will be deprecated.
In my (still beginning) experiments with akka streams I used ActorPublisher as a way to help create some back pressure controls while consuming messages from an external queue. This worked just by consuming the queue like normal and then for each message consumed, sending a message to ActorPublisher. Without using ActorPublisher, I can use a Source.actorRef, but that doesn't have back pressure controls. I know the recommended alternative to ActorPublisher is to use a custom graph stage and I have started experimenting with that but so far I don't see how to meet the ActorPublisher use case with it. So far it doesn't seem like a custom Source has an ActorRef type signature like Source.actorRef does. Once the custom stage is created, can I send a "tell" message to it the way I did to ActorPublisher? Or am I supposed to use Source.actorRef and then funnel it through the custom stage to get the back pressure controls? Sorry if my question is muddled, I am still making my way through this. :-) I recognize this is a bit weird since ideally the back pressure controls would be applied to the queueing tech itself. Curt -- >>>>>>>>>> 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 akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
