[jboss-cvs] JBoss Messaging SVN: r8061 - in branches/Branch_JBossMessaging_1_4_0_SP3_CP10_JBMESSAGING-1809: src/main/org/jboss/jms/client/remoting and 1 other directory.
jboss-cvs-commits at lists.jboss.org
jboss-cvs-commits at lists.jboss.org
Thu Jun 24 09:35:31 EDT 2010
Author: jbertram at redhat.com
Date: 2010-06-24 09:35:30 -0400 (Thu, 24 Jun 2010)
New Revision: 8061
Modified:
branches/Branch_JBossMessaging_1_4_0_SP3_CP10_JBMESSAGING-1809/.classpath
branches/Branch_JBossMessaging_1_4_0_SP3_CP10_JBMESSAGING-1809/src/main/org/jboss/jms/client/remoting/ClientSocketWrapper.java
Log:
JBPAPP-4488
Modified: branches/Branch_JBossMessaging_1_4_0_SP3_CP10_JBMESSAGING-1809/.classpath
===================================================================
--- branches/Branch_JBossMessaging_1_4_0_SP3_CP10_JBMESSAGING-1809/.classpath 2010-06-17 07:36:43 UTC (rev 8060)
+++ branches/Branch_JBossMessaging_1_4_0_SP3_CP10_JBMESSAGING-1809/.classpath 2010-06-24 13:35:30 UTC (rev 8061)
@@ -1,7 +1,8 @@
<?xml version="1.0" encoding="UTF-8"?>
<classpath>
<classpathentry kind="src" path="docs/examples/queue-failover/src"/>
- <classpathentry kind="src" path="integration/EAP4/src"/>
+ <classpathentry kind="src" path="jgroups-src"/>
+ <classpathentry kind="src" path="integration/EAP4/src/main"/>
<classpathentry kind="src" path="integration/EAP4/tests-src"/>
<classpathentry kind="src" path="docs/examples/bridge/src"/>
<classpathentry kind="src" path="docs/examples/stateless-clustered/src"/>
Modified: branches/Branch_JBossMessaging_1_4_0_SP3_CP10_JBMESSAGING-1809/src/main/org/jboss/jms/client/remoting/ClientSocketWrapper.java
===================================================================
--- branches/Branch_JBossMessaging_1_4_0_SP3_CP10_JBMESSAGING-1809/src/main/org/jboss/jms/client/remoting/ClientSocketWrapper.java 2010-06-17 07:36:43 UTC (rev 8060)
+++ branches/Branch_JBossMessaging_1_4_0_SP3_CP10_JBMESSAGING-1809/src/main/org/jboss/jms/client/remoting/ClientSocketWrapper.java 2010-06-24 13:35:30 UTC (rev 8061)
@@ -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");
More information about the jboss-cvs-commits
mailing list