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

[Ron Sigal]

  User: rsigal  
  Date: 07/11/06 03:41:08

  Modified:    src/tests/org/jboss/test/remoting/transport/bisocket  Tag:
                        remoting_2_x BisocketTestCase.java
  Log:
  JBREM-800:  In internalSetUp(), give Connector more time (and multiple tries) to start, in case port is in use. 
  
  Revision  Changes    Path
  No                   revision
  
  
  No                   revision
  
  
  1.1.2.19  +30 -6     JBossRemoting/src/tests/org/jboss/test/remoting/transport/bisocket/BisocketTestCase.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: BisocketTestCase.java
  ===================================================================
  RCS file: /cvsroot/jboss/JBossRemoting/src/tests/org/jboss/test/remoting/transport/bisocket/BisocketTestCase.java,v
  retrieving revision 1.1.2.18
  retrieving revision 1.1.2.19
  diff -u -b -r1.1.2.18 -r1.1.2.19
  --- BisocketTestCase.java	2 Nov 2007 23:40:29 -0000	1.1.2.18
  +++ BisocketTestCase.java	6 Nov 2007 08:41:08 -0000	1.1.2.19
  @@ -67,7 +67,7 @@
   
   /** 
    * @author <a href="ron.sigal at jboss.com">Ron Sigal</a>
  - * @version $Revision: 1.1.2.18 $
  + * @version $Revision: 1.1.2.19 $
    * <p>
    * Copyright Nov 25, 2006
    * </p>
  @@ -133,11 +133,35 @@
         config.put(Bisocket.PING_FREQUENCY, TEST_PING_FREQUENCY_STRING);
         config.put(MicroSocketClientInvoker.MAX_POOL_SIZE_FLAG, TEST_MAX_POOL_SIZE_STRING);
         addExtraServerConfig(config);
  +
  +      for (int i = 0; i < 5; i++)
  +      {
  +         try
  +         {
  +            if (i > 0)
  +            {
  +               log.info("will retry to start Connector");
  +            }
  +            
         connector = new Connector(serverLocator, config);
         connector.create();
         invocationHandler = new SampleInvocationHandler();
         connector.addInvocationHandler("sample", invocationHandler);
         connector.start();
  +            break;
  +         }
  +         catch (Exception e)
  +         {
  +            log.info("unable to start Connector for " + serverLocator);
  +            Thread.sleep(10000);
  +         }
  +      }
  +      
  +      if (connector == null || !connector.isStarted())
  +      {
  +         log.error("Unable to start Connector");
  +         throw new Exception("Unable to start Connector: " + serverLocator);
  +      }
      }