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

[jBoss CVS Development]

  User: norbert 
  Date: 00/06/14 17:45:03

  Modified:    src/java/org/spydermq JMSServerQueue.java Log.java
                        SpyConnection.java
  Log:
  Search: Scalibility issue ( test for 9000 publish / sec )
  
  Revision  Changes    Path
  1.9       +2 -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.8
  retrieving revision 1.9
  diff -u -r1.8 -r1.9
  --- JMSServerQueue.java       2000/06/05 03:19:23     1.8
  +++ JMSServerQueue.java       2000/06/15 00:45:02     1.9
  @@ -18,7 +18,7 @@
    *      
    *   @author Norbert Lataille ([EMAIL PROTECTED])
    * 
  - *   @version $Revision: 1.8 $
  + *   @version $Revision: 1.9 $
    */
   public class JMSServerQueue
   {
  @@ -251,7 +251,7 @@
                                //We can send multiple messages
                                Log.log("DISPATCH: "+msgs.length+" messages => 
"+destination);
                                sendMultipleMessages(msgs);
  -                     } else {
  +                     } else {        
                                //Send each message
                                for(int i=0;i<msgs.length;i++) {
                                        SpyMessage message=(SpyMessage)msgs[i];
  
  
  
  1.4       +2 -2      spyderMQ/src/java/org/spydermq/Log.java
  
  Index: Log.java
  ===================================================================
  RCS file: /products/cvs/ejboss/spyderMQ/src/java/org/spydermq/Log.java,v
  retrieving revision 1.3
  retrieving revision 1.4
  diff -u -r1.3 -r1.4
  --- Log.java  2000/06/14 23:21:00     1.3
  +++ Log.java  2000/06/15 00:45:02     1.4
  @@ -12,7 +12,7 @@
    *      
    *   @author Norbert Lataille ([EMAIL PROTECTED])
    * 
  - *   @version $Revision: 1.3 $
  + *   @version $Revision: 1.4 $
    */
   public class Log
   {
  @@ -21,7 +21,7 @@
        final static int LOG_ERRORS             = 3;
        
        //Change this line change the verbosity level
  -     final static int logType = LOG_EVERYTHING;
  +     final static int logType = LOG_ERRORS;
        
        private static void print(Object obj)
        {
  
  
  
  1.5       +4 -3      spyderMQ/src/java/org/spydermq/SpyConnection.java
  
  Index: SpyConnection.java
  ===================================================================
  RCS file: /products/cvs/ejboss/spyderMQ/src/java/org/spydermq/SpyConnection.java,v
  retrieving revision 1.4
  retrieving revision 1.5
  diff -u -r1.4 -r1.5
  --- SpyConnection.java        2000/06/05 03:19:23     1.4
  +++ SpyConnection.java        2000/06/15 00:45:02     1.5
  @@ -29,7 +29,7 @@
    *      
    *   @author Norbert Lataille ([EMAIL PROTECTED])
    * 
  - *   @version $Revision: 1.4 $
  + *   @version $Revision: 1.5 $
    */
   public class SpyConnection 
                implements Connection, Serializable
  @@ -236,7 +236,7 @@
                
                try {
   
  -                     for(int i=0;i<mes.length;i++) {
  +                     /*for(int i=0;i<mes.length;i++) {
                                
                                SpyMessage message=mes[i];
                                
  @@ -257,8 +257,9 @@
                                        //Alpha mode test + local delivery
                                }
                                
  -                     }
  +                     }*/
                        
  +                     Log.error("Size = "+mes.length);
                        provider.newMessage(mes,clientID);
                                                
                } catch (Exception e) {