[jboss-svn-commits] JBL Code SVN: r12912 - labs/jbossrules/trunk/drools-core/src/main/java/org/drools/concurrent.

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

Author: mark.proctor at jboss.com
Date: 2007-06-28 04:36:48 -0400 (Thu, 28 Jun 2007)
New Revision: 12912

Modified:
   labs/jbossrules/trunk/drools-core/src/main/java/org/drools/concurrent/AssertObjects.java
   labs/jbossrules/trunk/drools-core/src/main/java/org/drools/concurrent/CommandExecutor.java
   labs/jbossrules/trunk/drools-core/src/main/java/org/drools/concurrent/DefaultExecutorService.java
Log:
JBRULES-957 Async method calls don't work
-async method calls now work
-added stateless method call tests

Modified: labs/jbossrules/trunk/drools-core/src/main/java/org/drools/concurrent/AssertObjects.java
===================================================================
--- labs/jbossrules/trunk/drools-core/src/main/java/org/drools/concurrent/AssertObjects.java	2007-06-28 08:36:43 UTC (rev 12911)
+++ labs/jbossrules/trunk/drools-core/src/main/java/org/drools/concurrent/AssertObjects.java	2007-06-28 08:36:48 UTC (rev 12912)
@@ -22,7 +22,11 @@
 
     public void execute(final WorkingMemory workingMemory) {
         if ( this.object instanceof Object[] ) {
-            workingMemory.insert( this.object );
+            final Object[] objects = (Object[]) this.object;
+            for ( int i = 0; i < objects.length; i++ ) {
+                workingMemory.insert( objects[i] );
+            }
+            
         } else if ( this.object instanceof List ) {
             final List list = (List) this.object;
             this.results = new ArrayList( list.size() );

Modified: labs/jbossrules/trunk/drools-core/src/main/java/org/drools/concurrent/CommandExecutor.java
===================================================================
--- labs/jbossrules/trunk/drools-core/src/main/java/org/drools/concurrent/CommandExecutor.java	2007-06-28 08:36:43 UTC (rev 12911)
+++ labs/jbossrules/trunk/drools-core/src/main/java/org/drools/concurrent/CommandExecutor.java	2007-06-28 08:36:48 UTC (rev 12912)
@@ -32,6 +32,7 @@
     }
 
     public void run() {
+        this.run = true;
         while (this.run) {
             try {
                 Command executor = ( Command ) this.queue.take();

Modified: labs/jbossrules/trunk/drools-core/src/main/java/org/drools/concurrent/DefaultExecutorService.java
===================================================================
--- labs/jbossrules/trunk/drools-core/src/main/java/org/drools/concurrent/DefaultExecutorService.java	2007-06-28 08:36:43 UTC (rev 12911)
+++ labs/jbossrules/trunk/drools-core/src/main/java/org/drools/concurrent/DefaultExecutorService.java	2007-06-28 08:36:48 UTC (rev 12912)
@@ -20,6 +20,7 @@
     
     public void startUp() {
         this.thread = new Thread( executor );
+        this.thread.start();
         this.running = true;
     }