[jboss-cvs] jboss-jms/src/main/org/jboss/jms/server/connectionfactory ...

[Ovidiu Feodorov]

  User: ovidiu  
  Date: 06/07/26 17:16:26

  Modified:    src/main/org/jboss/jms/server/connectionfactory 
                        ConnectionFactory.java
  Log:
  ConnectionFactory logs as INFO the port and bind address used by its connector
  
  Revision  Changes    Path
  1.9       +11 -5     jboss-jms/src/main/org/jboss/jms/server/connectionfactory/ConnectionFactory.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: ConnectionFactory.java
  ===================================================================
  RCS file: /cvsroot/jboss/jboss-jms/src/main/org/jboss/jms/server/connectionfactory/ConnectionFactory.java,v
  retrieving revision 1.8
  retrieving revision 1.9
  diff -u -b -r1.8 -r1.9
  --- ConnectionFactory.java	17 Jul 2006 17:14:45 -0000	1.8
  +++ ConnectionFactory.java	26 Jul 2006 21:16:26 -0000	1.9
  @@ -11,6 +11,7 @@
   import org.jboss.jms.server.ConnectorManager;
   import org.jboss.jms.server.ServerPeer;
   import org.jboss.jms.server.ConnectionFactoryManager;
  +import org.jboss.remoting.InvokerLocator;
   import org.w3c.dom.Element;
   
   import javax.management.ObjectName;
  @@ -19,9 +20,9 @@
    * A deployable JBoss Messaging connection factory.
    *
    * @author <a href="mailto:ovidiu at jboss.org">Ovidiu Feodorov</a>
  - * @version <tt>$Revision: 1.8 $</tt>
  + * @version <tt>$Revision: 1.9 $</tt>
    *
  - * $Id: ConnectionFactory.java,v 1.8 2006/07/17 17:14:45 timfox Exp $
  + * $Id: ConnectionFactory.java,v 1.9 2006/07/26 21:16:26 ovidiu Exp $
    */
   public class ConnectionFactory extends ServiceMBeanSupport
   {
  @@ -100,15 +101,20 @@
         connectionFactoryID = connectionFactoryManager.
            registerConnectionFactory(clientID, jndiBindings, locatorURI, enablePing, prefetchSize);
                 
  +      InvokerLocator locator = new InvokerLocator(locatorURI);
  +      String info =
  +         "Connector " + locator.getProtocol() + "://" + locator.getHost() + ":" + locator.getPort();
  +              
         if (enablePing)
         {
  -         log.info("Connector has leasing enabled, lease period " + leasePeriod + " milliseconds");
  +         info += " has leasing enabled, lease period " + leasePeriod + " milliseconds";
         }
         else
         {
  -         log.info("Connector has lease disabled");
  +         info += " has lease disabled";
         }
         
  +      log.info(info);
         log.info(this + " deployed");
      }