From b2e77beb4603d9df613f23ff02f74944edc94f1f Mon Sep 17 00:00:00 2001
From: Norman Maurer <norman@apache.org>
Date: Tue, 1 May 2012 12:00:36 +0200
Subject: [PATCH] We need to set the exception on each MessageEvent. See #293

---
 .../java/io/netty/channel/socket/nio/AbstractNioWorker.java  | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/transport/src/main/java/io/netty/channel/socket/nio/AbstractNioWorker.java b/transport/src/main/java/io/netty/channel/socket/nio/AbstractNioWorker.java
index d57edde5ce..815c32f0d9 100644
--- a/transport/src/main/java/io/netty/channel/socket/nio/AbstractNioWorker.java
+++ b/transport/src/main/java/io/netty/channel/socket/nio/AbstractNioWorker.java
@@ -892,7 +892,7 @@ abstract class AbstractNioWorker implements Worker {
             }
         }
     }
-
+    
     protected void cleanUpWriteBuffer(AbstractNioChannel channel) {
         Exception cause = null;
         boolean fireExceptionCaught = false;
@@ -932,9 +932,10 @@ abstract class AbstractNioWorker implements Worker {
                     } else {
                         cause = new ClosedChannelException();
                     }
-                    evt.getFuture().setFailure(cause);
                     fireExceptionCaught = true;
                 }
+                evt.getFuture().setFailure(cause);
+
                
             }
         }