[jboss-cvs] JBoss Messaging SVN: r8129 - branches/Branch_JBossMessaging_1_4_6_GA_JBMESSAGING-1805_JBMESSAGING-1822_JBMESSAGING-1809/src/main/org/jboss/jms/client/remoting.

[jboss-cvs-commits at lists.jboss.org]

Author: jbertram at redhat.com
Date: 2010-11-09 14:50:52 -0500 (Tue, 09 Nov 2010)
New Revision: 8129

Modified:
   branches/Branch_JBossMessaging_1_4_6_GA_JBMESSAGING-1805_JBMESSAGING-1822_JBMESSAGING-1809/src/main/org/jboss/jms/client/remoting/ClientSocketWrapper.java
Log:
SOA-2526

Modified: branches/Branch_JBossMessaging_1_4_6_GA_JBMESSAGING-1805_JBMESSAGING-1822_JBMESSAGING-1809/src/main/org/jboss/jms/client/remoting/ClientSocketWrapper.java
===================================================================
--- branches/Branch_JBossMessaging_1_4_6_GA_JBMESSAGING-1805_JBMESSAGING-1822_JBMESSAGING-1809/src/main/org/jboss/jms/client/remoting/ClientSocketWrapper.java	2010-11-09 19:44:52 UTC (rev 8128)
+++ branches/Branch_JBossMessaging_1_4_6_GA_JBMESSAGING-1805_JBMESSAGING-1822_JBMESSAGING-1809/src/main/org/jboss/jms/client/remoting/ClientSocketWrapper.java	2010-11-09 19:50:52 UTC (rev 8129)
@@ -48,7 +48,7 @@
 {
    // Constants ------------------------------------------------------------------------------------
    final static private Logger log = Logger.getLogger(ClientSocketWrapper.class);
-   final static protected int CLOSING = 1;
+   final static protected int CLOSING = 254;
    
    // Static ---------------------------------------------------------------------------------------
 
@@ -104,7 +104,7 @@
    {
       if (log.isTraceEnabled()) log.trace("checking open connection");
 
-      if (((DataInputStream)getInputStream()).available() > 1)
+      if (((DataInputStream)getInputStream()).available() > 0)
       {
          log.trace("remote endpoint has closed");
          throw new IOException("remote endpoint has closed");