[jboss-remoting-commits] JBoss Remoting SVN: r4019 - in remoting3/trunk: jrpp/src/main/java/org/jboss/cx/remoting/jrpp and 1 other directory.

[jboss-remoting-commits at lists.jboss.org]

Author: david.lloyd at jboss.com
Date: 2008-04-18 19:04:38 -0400 (Fri, 18 Apr 2008)
New Revision: 4019

Modified:
   remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/CoreEndpoint.java
   remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppProtocolSupport.java
Log:
Use naming thread factory if no executor is specified

Modified: remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/CoreEndpoint.java
===================================================================
--- remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/CoreEndpoint.java	2008-04-18 23:01:53 UTC (rev 4018)
+++ remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/CoreEndpoint.java	2008-04-18 23:04:38 UTC (rev 4019)
@@ -24,6 +24,7 @@
 import org.jboss.cx.remoting.util.AtomicStateMachine;
 import org.jboss.cx.remoting.util.AttributeMap;
 import org.jboss.cx.remoting.util.CollectionUtil;
+import org.jboss.cx.remoting.util.NamingThreadFactory;
 import org.jboss.cx.remoting.version.Version;
 
 import javax.security.auth.callback.Callback;
@@ -115,7 +116,7 @@
     public void start() {
         // todo security check
         if (executor == null) {
-            executorService = Executors.newCachedThreadPool();
+            executorService = Executors.newCachedThreadPool(new NamingThreadFactory(Executors.defaultThreadFactory(), "Remoting endpoint %s"));
             setExecutor(executorService);
         }
         state.requireTransition(State.INITIAL, State.UP);

Modified: remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppProtocolSupport.java
===================================================================
--- remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppProtocolSupport.java	2008-04-18 23:01:53 UTC (rev 4018)
+++ remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppProtocolSupport.java	2008-04-18 23:04:38 UTC (rev 4019)
@@ -29,6 +29,7 @@
 import org.jboss.cx.remoting.spi.protocol.ProtocolHandler;
 import org.jboss.cx.remoting.spi.protocol.ProtocolHandlerFactory;
 import org.jboss.cx.remoting.util.AttributeMap;
+import org.jboss.cx.remoting.util.NamingThreadFactory;
 
 /**
  *
@@ -79,7 +80,7 @@
 
     public void create() throws RemotingException {
         if (executor == null) {
-            executor = executorService = Executors.newCachedThreadPool();
+            executor = executorService = Executors.newCachedThreadPool(new NamingThreadFactory(Executors.defaultThreadFactory(), "Remoting JRPP %s"));
         }
         ExceptionMonitor.setInstance(new ExceptionMonitor() {
             public void exceptionCaught(final Throwable cause) {