[jboss-cvs] JBoss Messaging SVN: r8086 - branches/JBossMessaging_1_4_6_GA_JBMESSAGING_1809/src/main/org/jboss/jms/client/remoting.
jboss-cvs-commits at lists.jboss.org
jboss-cvs-commits at lists.jboss.org
Thu Sep 30 00:50:33 EDT 2010
Author: bershath27
Date: 2010-09-30 00:50:32 -0400 (Thu, 30 Sep 2010)
New Revision: 8086
Modified:
branches/JBossMessaging_1_4_6_GA_JBMESSAGING_1809/src/main/org/jboss/jms/client/remoting/ClientSocketWrapper.java
Log:
Fixed : https://jira.jboss.org/browse/JBPAPP-5120
Ref : https://jira.jboss.org/browse/JBMESSAGING-1809
Modified: branches/JBossMessaging_1_4_6_GA_JBMESSAGING_1809/src/main/org/jboss/jms/client/remoting/ClientSocketWrapper.java
===================================================================
--- branches/JBossMessaging_1_4_6_GA_JBMESSAGING_1809/src/main/org/jboss/jms/client/remoting/ClientSocketWrapper.java 2010-09-30 03:14:20 UTC (rev 8085)
+++ branches/JBossMessaging_1_4_6_GA_JBMESSAGING_1809/src/main/org/jboss/jms/client/remoting/ClientSocketWrapper.java 2010-09-30 04:50:32 UTC (rev 8086)
@@ -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