[hornetq-commits] JBoss hornetq SVN: r11483 - branches/Branch_2_2_EAP/src/main/org/hornetq/core/remoting/server/impl.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2011-10-06 16:46:30 -0400 (Thu, 06 Oct 2011)
New Revision: 11483

Modified:
   branches/Branch_2_2_EAP/src/main/org/hornetq/core/remoting/server/impl/RemotingServiceImpl.java
Log:
Back porting HORNETQ-681

Modified: branches/Branch_2_2_EAP/src/main/org/hornetq/core/remoting/server/impl/RemotingServiceImpl.java
===================================================================
--- branches/Branch_2_2_EAP/src/main/org/hornetq/core/remoting/server/impl/RemotingServiceImpl.java	2011-10-06 20:37:57 UTC (rev 11482)
+++ branches/Branch_2_2_EAP/src/main/org/hornetq/core/remoting/server/impl/RemotingServiceImpl.java	2011-10-06 20:46:30 UTC (rev 11483)
@@ -52,6 +52,7 @@
 import org.hornetq.spi.core.remoting.BufferHandler;
 import org.hornetq.spi.core.remoting.Connection;
 import org.hornetq.spi.core.remoting.ConnectionLifeCycleListener;
+import org.hornetq.utils.ClassloadingUtil;
 import org.hornetq.utils.ConfigurationHelper;
 import org.hornetq.utils.HornetQThreadFactory;
 
@@ -117,13 +118,11 @@
 
       this.clusterManager = clusterManager;
 
-      ClassLoader loader = Thread.currentThread().getContextClassLoader();
       for (String interceptorClass : config.getInterceptorClassNames())
       {
          try
          {
-            Class<?> clazz = loader.loadClass(interceptorClass);
-            interceptors.add((Interceptor)clazz.newInstance());
+             interceptors.add((Interceptor) ClassloadingUtil.safeInitNewInstance(interceptorClass));
          }
          catch (Exception e)
          {