[jBoss-Dev] CVS update: spyderMQ/src/java/org/spydermq/serverClientConsumer.java JMSServer.java

[jBoss CVS Development]

  User: hiram   
  Date: 01/01/04 15:24:51

  Modified:    src/java/org/spydermq/server ClientConsumer.java
                        JMSServer.java
  Log:
  Bug Fix: message consumers would hang if it was delivered a message after it was 
closed.
  
  Revision  Changes    Path
  1.6       +2 -0      spyderMQ/src/java/org/spydermq/server/ClientConsumer.java
  
  Index: ClientConsumer.java
  ===================================================================
  RCS file: 
/products/cvs/ejboss/spyderMQ/src/java/org/spydermq/server/ClientConsumer.java,v
  retrieving revision 1.5
  retrieving revision 1.6
  diff -u -r1.5 -r1.6
  --- ClientConsumer.java       2001/01/03 23:25:06     1.5
  +++ ClientConsumer.java       2001/01/04 23:24:51     1.6
  @@ -27,7 +27,7 @@
    *
    *   @author Hiram Chirino ([EMAIL PROTECTED])
    * 
  - *   @version $Revision: 1.5 $
  + *   @version $Revision: 1.6 $
    */
   public class ClientConsumer implements Task {
   
  @@ -374,6 +374,8 @@
                try {
                        dc.cr.receive(job);
                } catch ( Exception e ) {
  +                     Log.notice("Could not send messages to a receiver.");
  +                     Log.notice(e);
                        server.connectionFailure(dc);
                }
                        
  
  
  
  1.11      +1 -1      spyderMQ/src/java/org/spydermq/server/JMSServer.java
  
  Index: JMSServer.java
  ===================================================================
  RCS file: /products/cvs/ejboss/spyderMQ/src/java/org/spydermq/server/JMSServer.java,v
  retrieving revision 1.10
  retrieving revision 1.11
  diff -u -r1.10 -r1.11
  --- JMSServer.java    2001/01/03 23:25:06     1.10
  +++ JMSServer.java    2001/01/04 23:24:51     1.11
  @@ -27,7 +27,7 @@
    *   @author Norbert Lataille ([EMAIL PROTECTED])
    *   @author Hiram Chirino ([EMAIL PROTECTED])
    * 
  - *   @version $Revision: 1.10 $
  + *   @version $Revision: 1.11 $
    */
   public class JMSServer 
                implements Runnable, JMSServerMBean
  @@ -399,7 +399,7 @@
                Log.log("JMSServer->connectionFailure(dc="+dc+")");
   
                //We should try again :) This behavior should under control of a 
Failure-Plugin         
  -             Log.error("I remove the Connection "+dc.getClientID()+" from the 
subscribers list");
  +             Log.error("The connection to client "+dc.getClientID()+" failed.");
   
                connectionClosing(dc);
        }