[akka-user] flatMapMerge and SupervisionStrategy

I'm using akka-kafka with committablePartitionedSource, meaning I have a source of (partition, innersource) tuples. I'm currently using the flatMapMerge recipe from https://doc.akka.io/docs/akka-stream-kafka/current/consumer.html#source-per-partition val done =

Re: [akka-user] Short lived persistent actors and deletion

On Fri, Oct 6, 2017 at 10:40 AM, Ole Hjalmar Herje wrote: > Ok. Do you know if it is it supported by other journal plugins? And is > leveldb stil not considered "production ready"? > LevelDB wasn't really *designed* to ever be "production ready", as far as I know. It

[akka-user] Re: Using Actors to send data to websockets

Have you read this: https://doc.akka.io/docs/akka-http/current/java/http/server-side/websocket-support.html -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html >> Search the

[akka-user] Using Actors to send data to websockets

I have been experimenting with Akka websockets and was able to send some static data to a websocket using the following code: import java.io.BufferedReader; import java.io.InputStreamReader; import java.util.concurrent.CompletionStage; import java.util.concurrent.TimeUnit;

Re: [akka-user] Short lived persistent actors and deletion

That is currently not supported but you could contribute that feature to the leveldb plugin. We could use Long.MaxValue as the signal to remove everything. /Patrik fre 6 okt. 2017 kl. 10:44 skrev Ole Hjalmar Herje : > Hi, is it possible to delete persistent actors

[akka-user] Short lived persistent actors and deletion

Hi, is it possible to delete persistent actors completely from the persistent storage? I have many short lived persistent actors with auto-generated unique persistenceId where I perform a deleteMessages(lastSequenceNr()) when they are done with their work. If the application restarts I perform

[akka-user] remote actor actorSystem.actorSelection("Actorpath").resolveOne(20.seconds) times out after several request processed.

Hi All, We are using Scala and Akka(version 2.4.0) in out application. We used remote actors and after processing several requests, actor resolve is timing out. here is the snippet of actor resolve. And we are running our application in Virtual machines. val a1 = Address("akka.tcp",

[akka-user] Re: Akka with Java: remote actor deploy with SpringExtension

I am also facing the same issue. Anything you got on this? On Thursday, 13 April 2017 02:10:00 UTC+5:30, Alexander Lukyanchikov wrote: > > Hi, > > We are using Akka with Java API, integrated with Spring Framework (each > actor is Prototype scope Spring bean) > There is no problem to create local