From 1c5d0bdf42e489dc60d9f28432ef5038defec38c Mon Sep 17 00:00:00 2001 From: Viktor Klang Date: Wed, 6 Jun 2012 14:04:02 +0200 Subject: [PATCH] Adding a FIXME --- akka-remote/src/main/scala/akka/remote/netty/Client.scala | 1 + 1 file changed, 1 insertion(+) diff --git a/akka-remote/src/main/scala/akka/remote/netty/Client.scala b/akka-remote/src/main/scala/akka/remote/netty/Client.scala index 76b400dd00..2d3748fb52 100644 --- a/akka-remote/src/main/scala/akka/remote/netty/Client.scala +++ b/akka-remote/src/main/scala/akka/remote/netty/Client.scala @@ -65,6 +65,7 @@ private[akka] abstract class RemoteClient private[akka] (val netty: NettyRemoteT new ChannelFutureListener { def operationComplete(future: ChannelFuture) { if (future.isCancelled || !future.isSuccess) { + //FIXME Should we just _not_ notifyListeners here and just assume that the other error reporting is sufficient? netty.notifyListeners(RemoteClientError(future.getCause, netty, remoteAddress)) val (message, sender, recipient) = request netty.system.deadLetters ! DeadLetter(message, sender.getOrElse(netty.system.deadLetters), recipient)