[jBoss-Dev] CVS update:spyderMQ/src/java/org/spydermq/distributed/serverDistributedJMSServerUIL.java DistributedJMSServerOIL.

[jBoss CVS Development]

  User: hiram   
  Date: 01/01/05 08:13:58

  Modified:    src/java/org/spydermq/distributed/server
                        DistributedJMSServerUIL.java
                        DistributedJMSServerOIL.java
  Log:
  Reduces the possiblity of an exception being displayed when a connection is being 
closed
  
  Revision  Changes    Path
  1.9       +6 -1      
spyderMQ/src/java/org/spydermq/distributed/server/DistributedJMSServerUIL.java
  
  Index: DistributedJMSServerUIL.java
  ===================================================================
  RCS file: 
/products/cvs/ejboss/spyderMQ/src/java/org/spydermq/distributed/server/DistributedJMSServerUIL.java,v
  retrieving revision 1.8
  retrieving revision 1.9
  diff -u -r1.8 -r1.9
  --- DistributedJMSServerUIL.java      2000/12/26 04:15:58     1.8
  +++ DistributedJMSServerUIL.java      2001/01/05 16:13:58     1.9
  @@ -41,7 +41,7 @@
    *   @author Norbert Lataille ([EMAIL PROTECTED])
    *   @author Hiram Chirino ([EMAIL PROTECTED])
    * 
  - *   @version $Revision: 1.8 $
  + *   @version $Revision: 1.9 $
    */
   public class DistributedJMSServerUIL
        implements Runnable, DistributedJMSServerSetup, DistributedJMSServerUILMBean
  @@ -120,6 +120,9 @@
                        try {
                                code=in.readByte();             
                        } catch (IOException e) {
  +                             if( closed )
  +                                     break;
  +                                     
                                Log.notice("Command read");
                                Log.notice(e);
                                break;
  @@ -225,6 +228,8 @@
                                        out.reset();
                                        out.flush();
                                } catch (IOException e2) {
  +                                     if( closed )
  +                                             break;
                                        failure("Result write",e2);
                                        break;                                  
                                }                               
  
  
  
  1.12      +4 -1      
spyderMQ/src/java/org/spydermq/distributed/server/DistributedJMSServerOIL.java
  
  Index: DistributedJMSServerOIL.java
  ===================================================================
  RCS file: 
/products/cvs/ejboss/spyderMQ/src/java/org/spydermq/distributed/server/DistributedJMSServerOIL.java,v
  retrieving revision 1.11
  retrieving revision 1.12
  diff -u -r1.11 -r1.12
  --- DistributedJMSServerOIL.java      2001/01/04 23:24:50     1.11
  +++ DistributedJMSServerOIL.java      2001/01/05 16:13:58     1.12
  @@ -39,7 +39,7 @@
    *   @author Norbert Lataille ([EMAIL PROTECTED])
    *   @author Hiram Chirino ([EMAIL PROTECTED])
    * 
  - *   @version $Revision: 1.11 $
  + *   @version $Revision: 1.12 $
    */
   public class DistributedJMSServerOIL extends DistributedJMSServerUIL
        implements DistributedJMSServerOILMBean
  @@ -77,6 +77,9 @@
                        try {
                                code=in.readByte();             
                        } catch (IOException e) {
  +                             if( closed )
  +                                     break;
  +                                     
                                Log.notice("Command read");
                                Log.notice(e);
                                break;