[jboss-cvs] JBossRemoting/src/main/org/jboss/remoting/transport/multiplex ...

[Ron Sigal]

  User: rsigal  
  Date: 07/03/27 04:15:06

  Modified:    src/main/org/jboss/remoting/transport/multiplex  Tag:
                        remoting_2_x OutputMultiplexor.java
  Log:
  JBREM-729: Added some exception messages to IOException catch clause.
  
  Revision  Changes    Path
  No                   revision
  
  
  No                   revision
  
  
  1.32.4.1  +7 -1      JBossRemoting/src/main/org/jboss/remoting/transport/multiplex/OutputMultiplexor.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: OutputMultiplexor.java
  ===================================================================
  RCS file: /cvsroot/jboss/JBossRemoting/src/main/org/jboss/remoting/transport/multiplex/OutputMultiplexor.java,v
  retrieving revision 1.32
  retrieving revision 1.32.4.1
  diff -u -b -r1.32 -r1.32.4.1
  --- OutputMultiplexor.java	23 Aug 2006 07:18:56 -0000	1.32
  +++ OutputMultiplexor.java	27 Mar 2007 08:15:06 -0000	1.32.4.1
  @@ -48,6 +48,8 @@
   import java.util.Map;
   import java.util.Set;
   
  +import javax.net.ssl.SSLException;
  +
   /**
    * <code>OutputMultiplexor</code> is one of the key Multiplex classes, responsible for
    * multiplexing multiple byte streams that share a single TCP connection.  It has an
  @@ -464,7 +466,11 @@
                           String message = e.getMessage();
                           if ("An existing connection was forcibly closed by the remote host".equals(message) ||
                               "An established connection was aborted by the software in your host machine".equals(message) ||
  -                            "Broken pipe".equals(message))
  +                            "Broken pipe".equals(message) ||
  +                            "Connection reset".equals(message) ||
  +                            "Connection closed by remote host".equals(message) ||
  +                            "Socket is closed".equals(message)
  +                            )
                           {
                              log.debug(e);
                              writeQueue.clear();