You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ar...@apache.org on 2008/08/20 15:06:57 UTC
svn commit: r687310 -
/incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/IoReceiver.java
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);