svn commit: r1071504 - /synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/util/concurrent/SynapseThreadPool.java

[supun]

Author: supun
Date: Thu Feb 17 05:25:14 2011
New Revision: 1071504

URL: http://svn.apache.org/viewvc?rev=1071504&view=rev
Log:
fixing an issue with having LikedBlockingDeque accidently

Modified:
    
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/util/concurrent/SynapseThreadPool.java

Modified: 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/util/concurrent/SynapseThreadPool.java
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/util/concurrent/SynapseThreadPool.java?rev=1071504&r1=1071503&r2=1071504&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/util/concurrent/SynapseThreadPool.java
 (original)
+++ 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/util/concurrent/SynapseThreadPool.java
 Thu Feb 17 05:25:14 2011
@@ -81,7 +81,7 @@ public class SynapseThreadPool extends T
     public SynapseThreadPool(int corePoolSize, int maxPoolSize, long 
keepAliveTime, int qlen,
         String threadGroup, String threadIdPrefix) {
         super(corePoolSize, maxPoolSize, keepAliveTime, TimeUnit.SECONDS,
-            qlen > 0 ? new LinkedBlockingQueue<Runnable>(qlen) : new 
LinkedBlockingDeque<Runnable>(),
+            qlen > 0 ? new LinkedBlockingQueue<Runnable>(qlen) : new 
LinkedBlockingQueue<Runnable>(),
             new SynapseThreadFactory(new ThreadGroup(threadGroup), 
threadIdPrefix));
     }
 }