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

[Tom Elrod]

  User: telrod  
  Date: 06/08/15 12:33:23

  Modified:    src/main/org/jboss/remoting/detection  AbstractDetector.java
  Log:
  JBREM-580 - fixed connection validator so that will not do ping if is ssl transport.
  
  Revision  Changes    Path
  1.26      +25 -8     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.25
  retrieving revision 1.26
  diff -u -b -r1.25 -r1.26
  --- AbstractDetector.java	24 Jul 2006 05:23:53 -0000	1.25
  +++ AbstractDetector.java	15 Aug 2006 16:33:23 -0000	1.26
  @@ -54,7 +54,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.25 $
  + * @version $Revision: 1.26 $
    */
   public abstract class AbstractDetector implements AbstractDetectorMBean
   {
  @@ -521,6 +521,22 @@
               ServerInvokerMetadata invokerMetadata = invokerMetadataArray[c];
               locator = invokerMetadata.getInvokerLocator();
   
  +            // added for JBREM-580 (don't use connection listener if is ssl)
  +            String transport = locator.getProtocol();
  +            boolean isSSL = false;
  +            try
  +            {
  +               isSSL = InvokerRegistry.isSSLSupported(transport);
  +            }
  +            catch(Exception e)
  +            {
  +               log.warn("Error when trying to determine if transport (" + transport + ") supports ssl when creating connection listener.");
  +               log.debug(e.getMessage(), e);
  +            }
  +
  +            // if is ssl, then assume is dead at this point
  +            if(!isSSL)
  +            {
               boolean isValid = ConnectionValidator.checkConnection(locator, null);
               if(isValid)
               {
  @@ -532,6 +548,7 @@
                     log.trace("Successful connection check for " + locator);
                  }
               }
  +            }
   
            }
            catch(Throwable ig)