diff --git a/dempsy-framework.impl/src/main/java/net/dempsy/transport/tcp/nio/NioReceiver.java b/dempsy-framework.impl/src/main/java/net/dempsy/transport/tcp/nio/NioReceiver.java index 7389442a..8386c18e 100644 --- a/dempsy-framework.impl/src/main/java/net/dempsy/transport/tcp/nio/NioReceiver.java +++ b/dempsy-framework.impl/src/main/java/net/dempsy/transport/tcp/nio/NioReceiver.java @@ -479,7 +479,12 @@ public void run() { continue; if(key.isReadable()) { - ((Client)key.attachment()).read(key); + try { + ((Client)key.attachment()).read(key); + } catch(final IOException cioe) { + LOGGER.warn(thisNode + " connection reset from client, closing: " + cioe.getMessage()); + ((Client)key.attachment()).closeup((SocketChannel)key.channel(), key); + } } else // this shouldn't be possible LOGGER.info(thisNode + " reciever got an unexpexted selection key " + key); }