1) resume supervisor strategy
2) Make receive final in the general EndpointActor and impl the
try-catch-reply there, and delegate the actual message processing to an
abstract method. That breaks down if using become, but otherwise it's fine.
/Patrik
lör 1 apr. 2017 kl. 21:17 skrev kraythe :
> Th
awaitAssert retries the block until it doesn't throw (or timeout)
/Patrik
fre 31 mars 2017 kl. 15:50 skrev Kilic Ali-Firat :
> Hi Akka Team,
>
> It's again me about the multi-nodes test that I'm doing to validate my
> cluster. I solve my issues about Master-Worker communication but I have a
> rea
Looks like you are still mixing Akka 2.3 and 2.4. That is not possible when
using Distributed PubSub. It was experimental in contrib in 2.3, and then
moved to cluster-tools in 2.4.
Note: Unimplemented deserialization of message with manifest
[akka.contrib.pattern.DistributedPubSubMediator$Internal
Such parameters must be read from config, i.e. you don't need different
mailbox classes, but have to have different configs for each one.
/Patrik
sön 26 mars 2017 kl. 08:50 skrev Sihan Li :
> Hi group,
>
> I have implemented a customized mailbox following this official document
> http://doc.akka.
I managed to solve the issue by using the Scala 2.11 versions of each
library as so:
com.typesafe.akka
akka-actor_2.11
2.4.17
com.typesafe.akka
akka-remote_2.11
2.4.17
com.typesafe.akka
akka-cluster-metrics_2.11
2.4.17
com.typesafe
config
And you accomplish this with the low level or DSL api.
On Saturday, April 8, 2017 at 12:56:26 AM UTC-5, rrodseth wrote:
>
> I use per-request actors. The only ask() is in the route, and is sent to a
> RequestHandler actor. The RequestHandler creates a per-request actor with
> the sender as a Pr
DSL.
Route contains:
onSuccess(requestHandler ? RequestHandler.AskForStatus) { ... }
On Sat, Apr 8, 2017 at 2:31 PM, kraythe wrote:
> And you accomplish this with the low level or DSL api.
>
> On Saturday, April 8, 2017 at 12:56:26 AM UTC-5, rrodseth wrote:
>>
>> I use per-request act