svn commit: r687310 - /incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/IoReceiver.java

[arnaudsimon]

Author: arnaudsimon
Date: Wed Aug 20 06:06:56 2008
New Revision: 687310

URL: http://svn.apache.org/viewvc?rev=687310&view=rev
Log:
qpid-1251: changed close method for closing the underlying socket on windows 
only.

Modified:
    
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/IoReceiver.java

Modified: 
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/IoReceiver.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/IoReceiver.java?rev=687310&r1=687309&r2=687310&view=diff
==============================================================================
--- 
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/IoReceiver.java
 (original)
+++ 
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/IoReceiver.java
 Wed Aug 20 06:06:56 2008
@@ -67,7 +67,14 @@
         {
             try
             {
-                socket.shutdownInput();
+                if (((String) 
System.getProperties().get("os.name")).matches("(?i).*windows.*"))
+                {
+                   socket.close();
+                }
+                else
+                {
+                    socket.shutdownInput();
+                }
                 if (Thread.currentThread() != this)
                 {
                     join(timeout);