diff --git a/akka-remote/src/main/scala/akka/remote/netty/NettyRemoteSupport.scala b/akka-remote/src/main/scala/akka/remote/netty/NettyRemoteSupport.scala index 89bd904c39..35019c1c8e 100644 --- a/akka-remote/src/main/scala/akka/remote/netty/NettyRemoteSupport.scala +++ b/akka-remote/src/main/scala/akka/remote/netty/NettyRemoteSupport.scala @@ -879,9 +879,13 @@ class RemoteServerHandler( case _ ⇒ None } - private def handleRemoteMessageProtocol(request: RemoteMessageProtocol, channel: Channel) = { + private def handleRemoteMessageProtocol(request: RemoteMessageProtocol, channel: Channel) = try { EventHandler.debug(this, "Received remote message [%s]".format(request)) dispatchToActor(request, channel) + } catch { + case e: Exception ⇒ + server.notifyListeners(RemoteServerError(e, server)) + EventHandler.error(e, this, e.getMessage) } private def dispatchToActor(request: RemoteMessageProtocol, channel: Channel) {