Re: [akka-user] How to shut down ActorSystem after all Actors have stopped?

2018-01-31 Thread santarupa100
Thanks Konrad. I'll test it out more.. On Wednesday, January 31, 2018 at 8:22:00 PM UTC-5, Konrad Malawski wrote: > > There is no reliable way to know what “everything is done” means. > This is because operations are asynchronous, and if you were to observe > “oh! nothing is in any mailbox!” the

Re: [akka-user] How to shut down ActorSystem after all Actors have stopped?

2018-01-31 Thread Konrad “ktoso” Malawski
There is no reliable way to know what “everything is done” means. This is because operations are asynchronous, and if you were to observe “oh! nothing is in any mailbox!” the next millisecond something may actually be in the mailbox, because it was just being asynchonously added. Shutting down the

[akka-user] How to shut down ActorSystem after all Actors have stopped?

2018-01-31 Thread santarupa100
Hi, Akka newbie here, I try the sample on Akka web site and notice the ActorSystem still runs after the Actors have finished, and I have to hit Enter to quit. Is there a way to shut down ActorSystem object once everything is done? I already tried the suggestion to override the reference.conf fi

[akka-user] Re: Swakka - a new extension to akka-http for Swagger/OpenApi

2018-01-31 Thread Philippe Derome
never mind, it's not needed, I had communication with Spark in mind and that does not require to be in same process. On Wednesday, January 31, 2018 at 12:45:53 PM UTC-5, Philippe Derome wrote: > > Jeremy, > > do you have any intent to make this project available with Scala 2.11? > > Phil > > > O

[akka-user] Re: Swakka - a new extension to akka-http for Swagger/OpenApi

2018-01-31 Thread Philippe Derome
Jeremy, do you have any intent to make this project available with Scala 2.11? Phil On Tuesday, January 30, 2018 at 5:21:52 PM UTC-5, Jeremy Townson wrote: > > Thanks for reporting this, Philippe. For anybody who experienced this > problem, fixed in > https://bitbucket.org/jtownson/swakka/co

[akka-user] [Akka-Streams-Kafka] Filter a committable stream

2018-01-31 Thread Nicolae Namolovan
Hello there, Was wondering if anybody has a suggestion how to filter messages from a committable kafka source while not loosing the committable offsets that needs to be committed after it was sent to a sink. Currently I'm reading from Kafka, filter and write the result to another kafka topic u

[akka-user] Re: [Akka-Streams] Want to always receive latest element in Sink

2018-01-31 Thread saloniv
Thanks for the answers @Tel Pressman and @Johannes Rudolph. I will try these approaches and write it here if they work. Thanks again. On Thursday, January 25, 2018 at 10:03:07 PM UTC+5:30, Johannes Rudolph wrote: > > Hi, > > in akka-stream, processing is usually run in a fused fashion, i.e. with