[jboss-cvs] JBossRemoting/src/tests/org/jboss/test/remoting/transport/socket/load ...

[Ron Sigal]

  User: rsigal  
  Date: 07/02/25 04:56:32

  Modified:    src/tests/org/jboss/test/remoting/transport/socket/load 
                        Tag: remoting_2_x SocketLoadTestCase.java
  Log:
  JBREM-710:  Additional logging has been added.
  
  Revision  Changes    Path
  No                   revision
  
  
  No                   revision
  
  
  1.2.6.2   +19 -3     JBossRemoting/src/tests/org/jboss/test/remoting/transport/socket/load/SocketLoadTestCase.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: SocketLoadTestCase.java
  ===================================================================
  RCS file: /cvsroot/jboss/JBossRemoting/src/tests/org/jboss/test/remoting/transport/socket/load/SocketLoadTestCase.java,v
  retrieving revision 1.2.6.1
  retrieving revision 1.2.6.2
  diff -u -b -r1.2.6.1 -r1.2.6.2
  --- SocketLoadTestCase.java	20 Dec 2006 09:09:47 -0000	1.2.6.1
  +++ SocketLoadTestCase.java	25 Feb 2007 09:56:32 -0000	1.2.6.2
  @@ -22,7 +22,12 @@
   package org.jboss.test.remoting.transport.socket.load;
   
   import junit.framework.TestCase;
  +
  +import org.apache.log4j.ConsoleAppender;
  +import org.apache.log4j.Level;
   import org.apache.log4j.Logger;
  +import org.apache.log4j.PatternLayout;
  +import org.jboss.logging.XLevel;
   import org.jboss.remoting.Client;
   import org.jboss.remoting.InvokerLocator;
   import org.jboss.remoting.transport.Connector;
  @@ -40,7 +45,7 @@
   //      Logger.getInstance("org.jboss.remoting.transport.socket").setLevel(Level.ALL);
   //   }
   
  -   private Logger logger = Logger.getRootLogger();
  +   private static Logger logger = Logger.getLogger(SocketLoadTestCase.class);
   
      protected String getTransport()
      {
  @@ -58,6 +63,15 @@
   
      public void setUp() throws Exception
      {
  +      logger.error("setUp()");
  +      Logger.getLogger("org.jboss.remoting").setLevel(XLevel.TRACE);
  +      Logger.getLogger("org.jboss.test.remoting").setLevel(Level.INFO);
  +      String pattern = "[%d{ABSOLUTE}] [%t] %5p (%F:%L) - %m%n";
  +      PatternLayout layout = new PatternLayout(pattern);
  +      ConsoleAppender consoleAppender = new ConsoleAppender(layout);
  +      Logger.getRootLogger().addAppender(consoleAppender); 
  +      
  +      logger.info("starting server");
         startServer();
      }
   
  @@ -72,6 +86,7 @@
   
      public void startServer() throws Exception
      {
  +      logger.info("startServer()");
         String locatorURI = getTransport() + "://localhost:54000/?maxPoolSize=2&timeout=10000";
         InvokerLocator locator = new InvokerLocator(locatorURI);
   
  @@ -89,7 +104,7 @@
      {
         runMultipleClients(numOfRunnerThreads);
         Thread.currentThread().sleep(120000);
  -      System.out.println("Response count = " + responseCount + ".  Expected 10.");
  +      logger.info("Response count = " + responseCount + ".  Expected 10.");
         assertEquals(10, responseCount);
      }
   
  @@ -100,9 +115,10 @@
         Client client = new Client(locator);
         client.connect();
         String req = clientId;
  +      logger.info("client.invoke() " + clientId);
         Object resp = client.invoke(req);
         responseCount++;
  -      System.out.println("Received response of: " + resp + ".  Response count = " + responseCount);
  +      logger.info("Received response of: " + resp + ".  Response count = " + responseCount);
         System.in.read();
      }