[akka-user] Re: Microservices Architecture with AKKA Cluster

Hi Maatary, Just an update that I had got from the Akka Team on my original stab at an implementation for this using those (apparently outdated) Activator Templates: "The tweet publisher is the glue from the eventStream to Akka Streams. As you say, there are other ways of doing this. For

Re: [akka-user] Get ActorSystem as part of a stream materialization process

(feel free to copy paste the entire impl and use as-is if you want to btw) -- Konrad `ktoso` Malawski Akka @ Lightbend On 31 July 2016 at 00:52:56, Konrad Malawski (konrad.malaw...@lightbend.com) wrote: I like the idea, this can indeed be very useful!

Re: [akka-user] Get ActorSystem as part of a stream materialization process

I like the idea, this can indeed be very useful! We'll see what the rest of the team has to say about it. I took a shot at implementing it actually, so here it is: https://github.com/akka/akka/pull/21076 No guarantees about bug-free ness, but it seems rather complete ;-) It also shows of how

Re: [akka-user] Get ActorSystem as part of a stream materialization process

I'm trying to bind stream life-cycle to an actor life-cycle (let's call it master actor). In a sense that if the stream is destroyed - the master actor receives some Termination message but stays alive, but if the actor is destroyed - the stream has to be shut down as well. When I construct part

Re: [akka-user] Get ActorSystem as part of a stream materialization process

Not using safe APIs. But instead I'd turn around the question and ask what you're trying to achieve? Perhaps there's a cleaner way than reaching out to the ActorSystem. -- Konrad `ktoso` Malawski Akka @ Lightbend On 30 July 2016 at 22:39:47, oleksiys

[akka-user] Get ActorSystem as part of a stream materialization process

Hi, is it possible to get access to the ActorSystem, that is being used to materialize the stream during materialization? Something like: Flow[String].viaMat(*ExposeActorSystemMat.instance*).mapMaterializedValue(actorSystem => doSomethingWithActorSystem(actorSystem)) Thanks. WBR, Alexey

Re: [akka-user] Cassandra persistence - with Cassandra 2.2.7 + akka-persistence-cassandra-0.7 + akka 2.4.8 - not working

I see you got things working, which is great. I just wanted to caution: On Sat, Jul 30, 2016 at 8:29 AM, Muthukumaran Kothandaraman < muthu.kmk2...@gmail.com> wrote: > I assume my application.conf below is fine because I do not see any > exceptions. > As a rule of thumb, this isn't a safe

[akka-user] Re: Cassandra persistence - with Cassandra 2.2.7 + akka-persistence-cassandra-0.7 + akka 2.4.8 - not working [SOLVED]

Moved to Cassandra version 3.7 and no other changes - it works now ! Just in case somebody is hitting same problem, this could be useful. Please note that this is purely localhost testing. Will start cluster testing sometime Regards Muthu On Saturday, 30 July 2016 17:59:07 UTC+5:30,

[akka-user] Cassandra persistence - with Cassandra 2.2.7 + akka-persistence-cassandra-0.7 + akka 2.4.8 - not working

Hi, With above combination I am getting following error while running a simple PersistentActor. Checked compatibility on page - https://github.com/akka/akka-persistence-cassandra Will give a try with [WARN] [07/30/2016 08:13:20.699] [example-cassandra-journal.default-dispatcher-6]