Re: [akka-user] Re: Akka persistence query examples

Hello, now I better understand queries like allPersistenceIds() and eventsByPersistenceId(persistenceId). What can I do if persistent query implementation I use does not support live stream of events? Should I implement polling myself (schedule message to self and after receive call query agai

[akka-user] How to obtain the effective uid of the remote process

Hi, I am new to Akka and am searching for a reliable way to obtain the effective UID/GID of a remote process. I am using remoting with SSL in untrusted mode successfully. And I have successfully used SNA to call geteuid() from the standard C library (I only need this application to run on Li

Re: [akka-user] Building Spark with Akka 2.4.0

Just an update on this - since I got the scala notations errors with SBT assembly I went back to the maven build and built with akka 2.3.11 and consumed it on my akka 2.4.1 SBT projects. Running on the spark cluster this gave problems as the loading order of the dependencies made it so that ak

[akka-user] Http().serverLayer as Reverse-Proxy on top of Source(s)[ByteString] ?

Hi together, I have some questions regarding the proper use of Http().serverLayer: We want to build a streaming pipeline, which accepts ByteStrings -> parses them as HTTP Requests -> sends them to a server -> receives the HTTP response -> and renders that as a ByteString. you could say a Rever

[akka-user] Akka Quartz Scheduler with/as cluster singleton

We use Akka Quartz Scheduler project today to run recurring jobs on each 'node' in our cluster. I now have requirements for jobs that need to be reliably scheduled/executed once per time period across a cluster and I do not believe this

[akka-user] Re: Deleting Specific Message in Akka-Persistence

Hi Not sure if this is still a problem for you. Faced with a similar type of problem I create persistent actors per "job" and have a master which keeps the state of all. This means that on recover, I quickly can see which of my jobs were completed and which not. So my "master" would have a struc

[akka-user] Are there any libraries that help me implementing a Micro-Service Archicteture with Akka?

Hi, If I have a bare bone Akka cluster running on n nodes with a fixed configuration. I am cosidering to build a system where one could deploy dynamically akka-jars to this cluster. These akka-jars should be isolated as much as possible from each other. (Maybe through different classloader