Hi All,
My use case is I want to create an Akka stream in which the source is a
java Queue. The stream should keep on the pooling values from the queue and
if the queue is empty then wait for the values in the queue. Akka stream
queue is another option but if in case of any failure I want to st
You could wrap your queue in a GraphStage, which will give you a lot of
flexibility.
There are a lot of good examples (include some with queues) at
https://doc.akka.io/docs/akka/current/stream/stream-customize.html#custom-processing-with-graphstage
BR, Felix
> Am 06.11.2019 um 16:14 schrieb Bis
Hi Felix,
Thank you for the response. I went through the link that you have shared
with me. But in the documentation, I saw that the queue is used as a flow
in the example. But in my use case, I want to use the queue as an Akka
stream source and then send it to an actor. It will be very helpful
