Justin,
Thanks for much for the code sample.
First of all let me say that I think I will have no more than 2 nodes at
first.
I think I was referring exactly to what you did but yours is much smarter.
The workaround I had in mind was to just "down" the unreachable member and
that´s all.
In my
If I'm understanding you correctly, that's not really any better than the
broken auto-down system built into Scala. You really need something
smarter for production.
*Conceptually*, there is a very straightforward strategy: when a node sees
nodes become unreachable, it checks whether it can see m
Hi,
I have a cluster with a few nodes running clustered sharding persistent
actors that I am close to deploy in prod
I tested that once a node is unreachable all the persistent actors inside
it are unreachable as well until human intervention takes places to Down
that unreachable node for the
Someone who can help me ???
On Saturday, September 2, 2017 at 3:53:20 PM UTC+4:30, techlan...@gmail.com
wrote:
>
> hi every one
> I'm using akka 2.5.x how can call Socket async for read and write ?(what
> is the best solution)
> i need many connection concurrency for send email this is sample c
I have the same question ?
On Wednesday, September 13, 2017 at 1:32:13 AM UTC+4:30, Yaroslav Klymko
wrote:
>
> Hi guys,
>
> I'm wondering are there any plans to provide integration between akka
> streams and PersistentActor ?
> The feature I'm interested in particular is `FlowOps.batch`, so I
If you're using Scala, just send the three sub-messages as a Tuple3 --
there's no real effort involved. Or add a case class for it: creating case
classes is near-trivial, and this sort of thing is what they're for.
If you're in Java, then yeah, you probably need to create a wrapper class...
On T
In http://doc.akka.io/docs/akka/2.5.4/scala/stream/stream-io.html, in the
example titled "Connecting: REPL Client", the code implies you can type 'q'
to end the REPL session, however it doesn't shutdown the ActorSystem, so
the process does not exit. What would you need to add to this code to cau
its works after including akka-stream dependency (transitive) with never
version.
"com.typesafe.akka" %% "akka-http" % "10.0.10",
"com.typesafe.akka" %% "akka-actor" % "2.5.4",
"com.typesafe.akka" %% "akka-stream" % "2.5.4",
"com.typesafe.akka" %% "akka-http-spray-json" % "10.0.10"
On
Hello all,
Is there a way to send multiple classes to Akka actors in a single tell/ask
call?
Say, actor X wants to send a message to Actor Y with three classes a,b,c,
and actor Y takes these 3 classes (a,b,c) and invokes a method y1 with
parameters (a,b,c). Is wrapping classes a,b,c with a new
