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

[jBoss CVS Development]

  User: norbert 
  Date: 00/05/31 18:14:31

  Modified:    src/java/org/spydermq/distributed/server
                        ConnectionReceiverRMIImpl.java
  Log:
  P2P system : fix for faulty clients
  
  Revision  Changes    Path
  1.2       +3 -4      
spyderMQ/src/java/org/spydermq/distributed/server/ConnectionReceiverRMIImpl.java
  
  Index: ConnectionReceiverRMIImpl.java
  ===================================================================
  RCS file: 
/products/cvs/ejboss/spyderMQ/src/java/org/spydermq/distributed/server/ConnectionReceiverRMIImpl.java,v
  retrieving revision 1.1
  retrieving revision 1.2
  diff -u -r1.1 -r1.2
  --- ConnectionReceiverRMIImpl.java    2000/05/31 18:10:16     1.1
  +++ ConnectionReceiverRMIImpl.java    2000/06/01 01:14:30     1.2
  @@ -29,7 +29,7 @@
    *      
    *   @author Norbert Lataille ([EMAIL PROTECTED])
    * 
  - *   @version $Revision: 1.1 $
  + *   @version $Revision: 1.2 $
    */
   public class ConnectionReceiverRMIImpl extends UnicastRemoteObject implements 
ConnectionReceiverRMI
   {
  @@ -102,12 +102,11 @@
                                if (sq.NumListeningSubscribers!=0) break;
                        }
                        if (sq==null||sq.NumListeningSubscribers==0) {
  -                             connectionQueue.NumListeningSessions=0;
  -                             Log.error("WARNING: The listeners count was invalid 
!");
  +                             Log.error("FIXME: The listeners count was invalid !");
                                throw new NoReceiverException("There are no listening 
sessions for this destination !");
                        }
   
  -                     //try/catch NoReceiverException
  +                     //try/catch NoReceiverException, and find someone else in the 
same connection !
                        sq.dispatchMessage(dest,mes);
                        
                }