Fix for https://atmosphere.dev.java.net/issues/show_bug.cgi?id=64

(" Set the default BroadcasterConfig ExecutorService size to 1 ") See issue description
Atmosphere · Oct 4, 2010 · 8c78a93 · 8c78a93
1 parent 1b9ac37
commit 8c78a93
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 4 deletions.
diff --git a/modules/cpr/src/main/java/org/atmosphere/cpr/AtmosphereServlet.java b/modules/cpr/src/main/java/org/atmosphere/cpr/AtmosphereServlet.java
@@ -568,9 +568,7 @@ protected void configureBroadcaster() throws ClassNotFoundException, Instantiati
                     Thread.currentThread().getContextClassLoader().loadClass(broadcasterCacheClassName).newInstance());
         }
 
-        logger.info("Using " + broadcasterClassName
-                + " with a Thread Pool size of : "
-                + BroadcasterConfig.numOfProcessor);
+        logger.info("Using " + broadcasterClassName);
     }
 
     /**

diff --git a/modules/cpr/src/main/java/org/atmosphere/cpr/BroadcasterConfig.java b/modules/cpr/src/main/java/org/atmosphere/cpr/BroadcasterConfig.java
@@ -81,7 +81,7 @@ public BroadcasterConfig(ExecutorService executorService, ScheduledExecutorServi
     }
 
     protected void configExecutors() {
-        executorService = Executors.newCachedThreadPool(new ThreadFactory(){
+        executorService = Executors.newSingleThreadExecutor(new ThreadFactory(){
 
             private AtomicInteger count = new AtomicInteger();