Author: david.lloyd(a)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) {