Hi, I got this fairly simple actor:
private def actor(state: Option[R], calc: () => Future[R]):
Actor.Immutable[Message] = Actor.immutable[Message] {
(_, msg) =>
msg match {
case Get(replyTo) =>
state match {
case Some(f) =>
replyTo ! f
Actor.
Did a quick test commenting out the blocking .awaitFor(). So there was no
blocking call. But still it is too slow.
--
>> Read the docs: http://akka.io/docs/
>> Check the FAQ:
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>> Search the
I am using the ask pattern to
system ? (ref => Get(key, ref))
where
private val system = ActorSystem(
Actor.supervise(guardian(Map.empty)).onFailure[Throwable](SupervisorStrategy.resume),
"EvaluateOnceFlushable"
)
Within the guardian actor, I create a children actor and forward the msg:
Hi,
We use Guice and we got an AkkaModule that creates an ActorSystem and a
Materializer that can later on be injected to other classes. I wonder if
there is a problem with that. My assumption is that if uses of the actor
system, materializer and dispatcer (used as ExecutionContext for Future's
I've created an akka cluster with this config on node 1 (flattened):
akka.cluster.roles : [
"distmem-server"
]
akka.logging-filter : "akka.event.slf4j.Slf4jLoggingFilter"
akka.remote.netty.tcp.hostname : "distmem.lan"* <--- this exists in my
hosts file and points to localhost, but tried 127.0
Hi, anyone knows if say I got 2 actors which send very quickly thousands of
small messages between them. Will akka do any groupping of the messages and
send them in batches in order to reduce network traffic?
Thanks
--
>> Read the docs: http://akka.io/docs/
>> Check t
