[jboss-cvs] JBossRemoting/src/main/org/jboss/remoting/detection ...

[Tom Elrod]

  User: telrod  
  Date: 06/07/21 16:02:22

  Modified:    src/main/org/jboss/remoting/detection  AbstractDetector.java
  Log:
  JBREM-553 - adding test case to try to reproduce.
  
  Revision  Changes    Path
  1.23      +6 -3      JBossRemoting/src/main/org/jboss/remoting/detection/AbstractDetector.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: AbstractDetector.java
  ===================================================================
  RCS file: /cvsroot/jboss/JBossRemoting/src/main/org/jboss/remoting/detection/AbstractDetector.java,v
  retrieving revision 1.22
  retrieving revision 1.23
  diff -u -b -r1.22 -r1.23
  --- AbstractDetector.java	3 Jul 2006 18:55:32 -0000	1.22
  +++ AbstractDetector.java	21 Jul 2006 20:02:22 -0000	1.23
  @@ -55,7 +55,7 @@
    *
    * @author <a href="mailto:jhaynie at vocalocity.net">Jeff Haynie</a>
    * @author <a href="mailto:tom.elrod at jboss.com">Tom Elrod</a>
  - * @version $Revision: 1.22 $
  + * @version $Revision: 1.23 $
    */
   public abstract class AbstractDetector implements AbstractDetectorMBean
   {
  @@ -517,11 +517,14 @@
         for(int c = 0; c < invokerMetadataArray.length; c++)
         {
            InvokerLocator locator = null;
  +         Map configMap = new HashMap();
  +         configMap.put("detector", "true");
            try
            {
               ServerInvokerMetadata invokerMetadata = invokerMetadataArray[c];
               locator = invokerMetadata.getInvokerLocator();
  -            ClientInvoker ci = InvokerRegistry.createClientInvoker(locator);
  +
  +            ClientInvoker ci = InvokerRegistry.createClientInvoker(locator, configMap);
   
               if(ci.isConnected() == false)
               {
  @@ -549,7 +552,7 @@
                  log.trace(ig);
               }
               // remove the client invoker, it's not any good anymore
  -            InvokerRegistry.destroyClientInvoker(locator, null);
  +            InvokerRegistry.destroyClientInvoker(locator, configMap);
               // will be aggressive with removal.  if any fail, remove it.
               // if still good, will pick up detection again next go around.
            }