[hornetq-commits] JBoss hornetq SVN: r7888 - trunk/src/main/org/hornetq/core/server/impl.

[do-not-reply at jboss.org]

Author: timfox
Date: 2009-08-22 07:58:41 -0400 (Sat, 22 Aug 2009)
New Revision: 7888

Modified:
   trunk/src/main/org/hornetq/core/server/impl/HornetQServerImpl.java
Log:
https://jira.jboss.org/jira/browse/HORNETQ-109

Modified: trunk/src/main/org/hornetq/core/server/impl/HornetQServerImpl.java
===================================================================
--- trunk/src/main/org/hornetq/core/server/impl/HornetQServerImpl.java	2009-08-22 11:45:17 UTC (rev 7887)
+++ trunk/src/main/org/hornetq/core/server/impl/HornetQServerImpl.java	2009-08-22 11:58:41 UTC (rev 7888)
@@ -228,8 +228,8 @@
    }
 
    public HornetQServerImpl(Configuration configuration,
-                              MBeanServer mbeanServer,
-                              final HornetQSecurityManager securityManager)
+                            MBeanServer mbeanServer,
+                            final HornetQSecurityManager securityManager)
    {
       if (configuration == null)
       {
@@ -896,8 +896,7 @@
       executorFactory = new OrderedExecutorFactory(threadPool);
 
       scheduledPool = new ScheduledThreadPoolExecutor(configuration.getScheduledThreadPoolMaxSize(),
-                                                      new HornetQThreadFactory("HornetQ-scheduled-threads",
-                                                                                                     false));
+                                                      new HornetQThreadFactory("HornetQ-scheduled-threads", false));
 
       managementService = new ManagementServiceImpl(mbeanServer, configuration, managementConnectorID);
 
@@ -1388,11 +1387,13 @@
       if (version.getIncrementingVersion() != incrementingVersion)
       {
          log.warn("Client with version " + incrementingVersion +
+                  " and address " +
+                  connection.getRemoteAddress() +
                   " is not compatible with server version " +
                   version.getFullVersion() +
                   ". " +
                   "Please ensure all clients and servers are upgraded to the same version for them to " +
-                  "interoperate");
+                  "interoperate properly");
          return null;
       }