[jboss-cvs] JBossRemoting/src/tests/org/jboss/test/remoting/detection/multicast ...

[Tom Elrod]

  User: telrod  
  Date: 06/08/22 23:57:38

  Modified:    src/tests/org/jboss/test/remoting/detection/multicast 
                        MulticastUnitTestCase.java
  Log:
  JBREM-586 - fixed socket client invoker so is back to having bounded connection pool
  
  Revision  Changes    Path
  1.8       +26 -18    JBossRemoting/src/tests/org/jboss/test/remoting/detection/multicast/MulticastUnitTestCase.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: MulticastUnitTestCase.java
  ===================================================================
  RCS file: /cvsroot/jboss/JBossRemoting/src/tests/org/jboss/test/remoting/detection/multicast/MulticastUnitTestCase.java,v
  retrieving revision 1.7
  retrieving revision 1.8
  diff -u -b -r1.7 -r1.8
  --- MulticastUnitTestCase.java	6 Jul 2006 03:12:40 -0000	1.7
  +++ MulticastUnitTestCase.java	23 Aug 2006 03:57:38 -0000	1.8
  @@ -69,7 +69,7 @@
         reg2.addNotificationListener(notif2, null, null);
         
         // Need to allow heartbeat so have detection
  -      Thread.sleep(2000);
  +      Thread.currentThread().sleep(5000);
   
         //Should now have an entry for both of the registries
         int reg1Count = reg1.getServers().length;
  @@ -258,28 +258,36 @@
         
         public void handleNotification( Notification notification, Object o )
         {
  +         System.out.println("TestNotificationListner.handleNotification() called.");
  +
            if ( notification instanceof NetworkNotification )
            {
               NetworkNotification networkNotification = (NetworkNotification) notification;
   
               if ( NetworkNotification.SERVER_ADDED.equals( networkNotification.getType() ) )
               {
  +               System.out.println("SERVER_ADDED notification.");
                  for (int i = 0; i < networkNotification.getLocator().length; i++)
                  {
  +                  System.out.println("ADDED: " + networkNotification.getLocator()[i]);
                     notifLog.add("ADDED: " + networkNotification.getLocator()[i]);
                  }
               }
               else if ( NetworkNotification.SERVER_REMOVED.equals( networkNotification.getType() ) )
               {
  +               System.out.println("SERVER_REMOVED notification.");
                  for (int i = 0; i < networkNotification.getLocator().length; i++)
                  {
  +                  System.out.println("REMOVED: " + networkNotification.getLocator()[i]);
                     notifLog.add("REMOVED: " + networkNotification.getLocator()[i]);
                  }
               }
               else if ( NetworkNotification.SERVER_UPDATED.equals( networkNotification.getType() ) )
               {
  +               System.out.println("SERVER_UPDATED notification.");
                  for (int i = 0; i < networkNotification.getLocator().length; i++)
                  {
  +                  System.out.println("UPDATED: " + networkNotification.getLocator()[i]);
                     notifLog.add("UPDATED: " + networkNotification.getLocator()[i]);
                  }
               }