svn commit: r920274 - /tuscany/sca-java-1.x/trunk/modules/implementation-bpel-ode/src/main/java/org/apache/tuscany/sca/implementation/bpel/ode/EmbeddedODEServer.java

[nash]

Author: nash
Date: Mon Mar  8 11:17:14 2010
New Revision: 920274

URL: http://svn.apache.org/viewvc?rev=920274&view=rev
Log:
Update thread pool creation code to match the corresponding code in ODE 1.3.3 
(TUSCANY-3475)

Modified:
    
tuscany/sca-java-1.x/trunk/modules/implementation-bpel-ode/src/main/java/org/apache/tuscany/sca/implementation/bpel/ode/EmbeddedODEServer.java

Modified: 
tuscany/sca-java-1.x/trunk/modules/implementation-bpel-ode/src/main/java/org/apache/tuscany/sca/implementation/bpel/ode/EmbeddedODEServer.java
URL: 
http://svn.apache.org/viewvc/tuscany/sca-java-1.x/trunk/modules/implementation-bpel-ode/src/main/java/org/apache/tuscany/sca/implementation/bpel/ode/EmbeddedODEServer.java?rev=920274&r1=920273&r2=920274&view=diff
==============================================================================
--- 
tuscany/sca-java-1.x/trunk/modules/implementation-bpel-ode/src/main/java/org/apache/tuscany/sca/implementation/bpel/ode/EmbeddedODEServer.java
 (original)
+++ 
tuscany/sca-java-1.x/trunk/modules/implementation-bpel-ode/src/main/java/org/apache/tuscany/sca/implementation/bpel/ode/EmbeddedODEServer.java
 Mon Mar  8 11:17:14 2010
@@ -26,6 +26,7 @@
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
+import java.util.concurrent.ThreadFactory;
 
 import javax.transaction.TransactionManager;
 import javax.xml.namespace.QName;
@@ -147,9 +148,18 @@
         if (__log.isDebugEnabled()) {
             __log.debug("ODE initializing");
         }
+        ThreadFactory threadFactory = new ThreadFactory() {
+            int threadNumber = 0;
+            public Thread newThread(Runnable r) {
+                threadNumber += 1;
+                Thread t = new Thread(r, "EmbeddedODEServer-"+threadNumber);
+                t.setDaemon(true);
+                return t;
+            }
+        };
         
         //FIXME: externalize the configuration for ThreadPoolMaxSize
-        _executorService = Executors.newCachedThreadPool();
+        _executorService = Executors.newCachedThreadPool(threadFactory);
        
         _bpelServer = new BpelServerImpl();
         _scheduler = createScheduler();
@@ -222,6 +232,7 @@
 
     protected Scheduler createScheduler() {
         SimpleScheduler scheduler = new SimpleScheduler(new 
GUID().toString(),new JdbcDelegate(_db.getDataSource()));
+        scheduler.setExecutorService(_executorService);
         scheduler.setTransactionManager(_txMgr);
 
         return scheduler;