svn commit: r1157367 - in /camel/trunk/camel-core/src/main/java/org/apache/camel: impl/ServiceSupport.java spi/ExecutorServiceFactory.java spi/ThreadPoolProfile.java

[da...@apache.org]

Author: davsclaus
Date: Sat Aug 13 11:03:59 2011
New Revision: 1157367

URL: http://svn.apache.org/viewvc?rev=1157367&view=rev
Log:
Polished

Removed:
    camel/trunk/camel-core/src/main/java/org/apache/camel/spi/ExecutorServiceFactory.java
Modified:
    camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ServiceSupport.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/spi/ThreadPoolProfile.java

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ServiceSupport.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ServiceSupport.java?rev=1157367&r1=1157366&r2=1157367&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ServiceSupport.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ServiceSupport.java Sat Aug 13 11:03:59 2011
@@ -38,6 +38,8 @@ import org.apache.camel.util.ServiceHelp
  */
 public abstract class ServiceSupport implements Service, ShutdownableService {
 
+    // TODO: Camel 3.0 consider moving this to org.apache.camel.util
+
     private final AtomicBoolean started = new AtomicBoolean(false);
     private final AtomicBoolean starting = new AtomicBoolean(false);
     private final AtomicBoolean stopping = new AtomicBoolean(false);

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/spi/ThreadPoolProfile.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/spi/ThreadPoolProfile.java?rev=1157367&r1=1157366&r2=1157367&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/spi/ThreadPoolProfile.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/spi/ThreadPoolProfile.java Sat Aug 13 11:03:59 2011
@@ -16,6 +16,7 @@
  */
 package org.apache.camel.spi;
 
+import java.io.Serializable;
 import java.util.concurrent.RejectedExecutionHandler;
 import java.util.concurrent.TimeUnit;
 
@@ -23,10 +24,16 @@ import org.apache.camel.ThreadPoolReject
 
 /**
  * A profile which defines thread pool settings.
+ * <p/>
+ * See more details at <a href="http://camel.apache.org/threading-model.html">threading model</a>
  *
  * @version 
  */
-public class ThreadPoolProfile {
+public class ThreadPoolProfile implements Serializable {
+
+    // TODO: Camel 2.9/3.0 consider moving to org.apache.camel
+
+    private static final long serialVersionUID = 1L;
 
     private String id;
     private Boolean defaultProfile;
@@ -214,8 +221,9 @@ public class ThreadPoolProfile {
 
     @Override
     public String toString() {
-        return "ThreadPoolProfile[" + id + ", " + defaultProfile + ", " + poolSize + ", " + maxPoolSize + ", "
-                + keepAliveTime + " " + timeUnit + ", " + maxPoolSize + ", " + rejectedPolicy + "]";
+        return "ThreadPoolProfile[" + id + " (" + defaultProfile + ") size:" + poolSize + "-" + maxPoolSize
+                + ", keepAlive: " + keepAliveTime + " " + timeUnit + ", maxQueue: " + maxQueueSize
+                + ", rejectedPolicy:" + rejectedPolicy + "]";
     }
 
 }