From 9e171cd92aeb446b080231ae100d75f4d2b0dfe4 Mon Sep 17 00:00:00 2001
From: Arnaud Simon <arnaudsimon@apache.org>
Date: Tue, 23 Oct 2007 12:28:24 +0000
Subject: cahnged for handling IO write errors

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@587476 13f79535-47bb-0310-9956-ffa450edef68
---
 .../java/org/apache/qpidity/transport/network/mina/MinaHandler.java   | 1 +
 .../java/org/apache/qpidity/transport/network/mina/MinaSender.java    | 4 ++++
 2 files changed, 5 insertions(+)

(limited to 'java/common/src')

diff --git a/java/common/src/main/java/org/apache/qpidity/transport/network/mina/MinaHandler.java b/java/common/src/main/java/org/apache/qpidity/transport/network/mina/MinaHandler.java
index 6362a6453b..cd4ae08102 100644
--- a/java/common/src/main/java/org/apache/qpidity/transport/network/mina/MinaHandler.java
+++ b/java/common/src/main/java/org/apache/qpidity/transport/network/mina/MinaHandler.java
@@ -88,6 +88,7 @@ public class MinaHandler<E> implements IoHandler
     public void exceptionCaught(IoSession ssn, Throwable e)
     {
         log.error(e, "exception caught");
+        throw new RuntimeException("IOException", e);
     }
 
     public void sessionCreated(final IoSession ssn)
diff --git a/java/common/src/main/java/org/apache/qpidity/transport/network/mina/MinaSender.java b/java/common/src/main/java/org/apache/qpidity/transport/network/mina/MinaSender.java
index c9032554fa..6906c03cb6 100644
--- a/java/common/src/main/java/org/apache/qpidity/transport/network/mina/MinaSender.java
+++ b/java/common/src/main/java/org/apache/qpidity/transport/network/mina/MinaSender.java
@@ -50,6 +50,10 @@ public class MinaSender implements Sender<java.nio.ByteBuffer>
     {
         synchronized (lock)
         {
+            if( session.isClosing())
+            {
+                throw new RuntimeException("Trying to write on a closed socket");
+            }
             lastWrite = session.write(ByteBuffer.wrap(buf));
         }
     }
-- 
cgit v1.2.1