[akka-user] akka.remote.transport.Transport$InvalidAssociationException: connection timed out while I can telnet the remote port

2014-12-10 Thread JasonQ
Hello Akka friends, We have 2 computers each has an Akka actor to communicate with each other. Somehow after some time the actorA on computer A can't connect to actorB on computer B with following logs from actor A: 2014-12-11 00:10:44,449 Remoting WARN

[akka-user] How to filter out unwanted message based on IP Address

2014-11-14 Thread JasonQ
Hello, I'm wondering whether AKKA has some mechanism which can be used to filter out incoming message based on IP Address, e.g. if I don't want to process messages from some specific node, how should I do? Thanks. -- Read the docs: http://akka.io/docs/ Check the FAQ:

Re: [akka-user] Difference between ClusterReceptionistExtension(system).registerService and DistributedPubSubMediator.Put

2014-08-18 Thread JasonQ
wrote: Hi, The registerService call right now only uses DistributedPubSubMediator.Put. There is no difference at all at the moment. There might be in the future though. B/ On 18 August 2014 at 07:10:31, JasonQ (quqin...@gmail.com javascript:) wrote: Hello, Per my understanding

[akka-user] Difference between ClusterReceptionistExtension(system).registerService and DistributedPubSubMediator.Put

2014-08-17 Thread JasonQ
Hello, Per my understanding after going through AKKA document, if I want to use mediator to send message to some actor in the cluster , I need use DistributedPubSubMediator.Put. When using ClusterClient.send, there's sample code using registerService in the doc instead of