[jboss-cvs] JBossAS SVN: r99358 - projects/jboss-threads/trunk/jbossmc/src/main/java/org/jboss/threads/metadata.

[jboss-cvs-commits at lists.jboss.org]

Author: david.lloyd at jboss.com
Date: 2010-01-13 15:58:14 -0500 (Wed, 13 Jan 2010)
New Revision: 99358

Modified:
   projects/jboss-threads/trunk/jbossmc/src/main/java/org/jboss/threads/metadata/ThreadsHelper.java
Log:
Fix wrong method invocation

Modified: projects/jboss-threads/trunk/jbossmc/src/main/java/org/jboss/threads/metadata/ThreadsHelper.java
===================================================================
--- projects/jboss-threads/trunk/jbossmc/src/main/java/org/jboss/threads/metadata/ThreadsHelper.java	2010-01-13 20:40:07 UTC (rev 99357)
+++ projects/jboss-threads/trunk/jbossmc/src/main/java/org/jboss/threads/metadata/ThreadsHelper.java	2010-01-13 20:58:14 UTC (rev 99358)
@@ -162,6 +162,10 @@
         return new QueueExecutor(corePoolSize, maxPoolSize, keepAliveTime, keepAliveTimeUnit, queue, threadFactory, blocking, handoffExecutor, createTaskFilter(taskFilterObjects)); 
     }
 
+    static QueuelessExecutor createQueuelessExecutor(final ThreadFactory threadFactory, final List<Object> taskFilterObjects, final Executor handoffExecutor, final long idleTimeout) {
+        return new QueuelessExecutor(threadFactory, createTaskFilter(taskFilterObjects), handoffExecutor, idleTimeout);
+    }
+
     static int calculateScaledCount(ScaledCountMetaData poolSizeMetaData) {
         float count = poolSizeMetaData.getCount();
         float perCpu = poolSizeMetaData.getPerCpu();
@@ -424,7 +428,7 @@
         final TaskFilterMetaData taskFilter = metaData.getTaskFilter();
         if (taskFilter != null) {
             builder.setFactoryClass(ThreadsHelper.class.getName());
-            builder.setFactoryMethod("createQueueExecutor");
+            builder.setFactoryMethod("createQueuelessExecutor");
             final List<ValueMetaData> list = builder.createList(ArrayList.class.getName(), Object.class.getName());
             for (AbstractTaskFilter filter : taskFilter.getTaskFilters()) {
                 filter.addTo(builder, list);