[jBoss-Dev] CVS update: spyderMQ/src/java/org/spydermqJMSServerQueue.java

[jBoss CVS Development]

  User: norbert 
  Date: 00/05/31 19:38:49

  Modified:    src/java/org/spydermq JMSServerQueue.java
  Log:
  P2P : Fixes
  
  Revision  Changes    Path
  1.6       +13 -2     spyderMQ/src/java/org/spydermq/JMSServerQueue.java
  
  Index: JMSServerQueue.java
  ===================================================================
  RCS file: /products/cvs/ejboss/spyderMQ/src/java/org/spydermq/JMSServerQueue.java,v
  retrieving revision 1.5
  retrieving revision 1.6
  diff -u -r1.5 -r1.6
  --- JMSServerQueue.java       2000/06/01 01:14:29     1.5
  +++ JMSServerQueue.java       2000/06/01 02:38:49     1.6
  @@ -18,7 +18,7 @@
    *      
    *   @author Norbert Lataille ([EMAIL PROTECTED])
    * 
  - *   @version $Revision: 1.5 $
  + *   @version $Revision: 1.6 $
    */
   public class JMSServerQueue
   {
  @@ -239,7 +239,7 @@
                removeSubscriber(dc,i);
        }
        
  -     void doMyJob()
  +     void doMyJob() 
        {                       
                if (isTopic) {                  
                        
  @@ -293,6 +293,17 @@
                                //Send the message
                                try {
                                        dc.cr.receive(destination,mes);
  +                             } catch (NoReceiverException e) {
  +                                     
  +                                     Log.log(e);
  +
  +                                     try {
  +                                             addMessage(mes);
  +                                             connectionListening(false,dc);
  +                                     } catch (Exception e2) {
  +                                             Log.error(e2);
  +                                     }                               
  +
                                } catch (Exception e) {
                                        
                                        try {