H Bryan, On 3 March 2014 at 16:17:57, bryan hunt ([email protected]) wrote:
And, if this is normal behaviour, is there any way of catching all incorrectly addressed messages received from a remote actor system? On 3 Mar 2014, at 15:06, bryan hunt <[email protected]> wrote: > Oh. I should point out that I'm sending the message using Akka Remoting. > > On 3 Mar 2014, at 15:04, bryan hunt <[email protected]> wrote: > >> Hi there, >> >> Pretty simple use case, I register an event handler and then send messages >> to an actor which does not exist. >> >> >> import akka.actor.{Actor, DeadLetter, Props} >> >> class Listener extends Actor { >> def receive = { >> case d: DeadLetter => >> System.err.println(s"DEAD LETTER - Sender ${d.message} , Recipient >> ${d.recipient}, Message: ${d.message}") >> case other => System.err.println(s"received $other") >> } >> } >> >> val listener = as.actorOf(Props(classOf[Listener], this)) >> as.eventStream.subscribe(listener, classOf[DeadLetter]) >> >> But the messages on console are lacking information about the recipient, and >> the contents of the messages are discarded, e.g >> >> [DEBUG] [03/03/2014 15:00:24.149] >> [s3uploader-service-akka.actor.default-dispatcher-3] >> [akka://s3uploader-service/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fs3upload-service-client%40127.0.0.1%3A6662-0/endpointWriter] >> received local message RemoteMessage: >> [SelectChildName(user,SelectChildName(processors,SelectChildName(s3dfdduploader,S3Request(/Users/bryanhunt/Pictures/old/uzi.jpg,1234-5678))))] >> to [Actor[akka://s3uploader-service/]]<+[akka://s3uploader-service/] from >> [Actor[akka.tcp://[email protected]:6662/temp/$a]] >> >> [DEBUG] [03/03/2014 15:00:32.570] >> [s3uploader-service-akka.actor.default-dispatcher-4] >> [akka://s3uploader-service/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fs3upload-service-client%40127.0.0.1%3A6662-0/endpointWriter] >> Disassociated [akka.tcp://[email protected]:6661] <- >> [akka.tcp://[email protected]:6662] >> >> DEAD LETTER - Sender DisassociateUnderlying(Unknown) , Recipient >> Actor[akka://s3uploader-service/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fs3uploader-service%40127.0.0.1%3A64491-1#-1155357421], >> Message: DisassociateUnderlying(Unknown) > The DisassociateUnderlying message is a local message that is sent when tearing down a remote connection. Which message did you send and what was the output from that? B/ -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: http://akka.io/faq/ >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to [email protected]. To post to this group, send email to [email protected]. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/groups/opt_out. -- Björn Antonsson Typesafe – Reactive Apps on the JVM twitter: @bantonsson -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to [email protected]. To post to this group, send email to [email protected]. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/groups/opt_out.
