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

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

Author: tirelli
Date: 2008-08-30 11:19:37 -0400 (Sat, 30 Aug 2008)
New Revision: 22258

Modified:
   labs/jbossrules/trunk/drools-core/src/main/java/org/drools/reteoo/AsyncCompositeObjectSinkAdapter.java
Log:
fixing bug

Modified: labs/jbossrules/trunk/drools-core/src/main/java/org/drools/reteoo/AsyncCompositeObjectSinkAdapter.java
===================================================================
--- labs/jbossrules/trunk/drools-core/src/main/java/org/drools/reteoo/AsyncCompositeObjectSinkAdapter.java	2008-08-30 12:09:07 UTC (rev 22257)
+++ labs/jbossrules/trunk/drools-core/src/main/java/org/drools/reteoo/AsyncCompositeObjectSinkAdapter.java	2008-08-30 15:19:37 UTC (rev 22258)
@@ -29,6 +29,9 @@
  */
 public class AsyncCompositeObjectSinkAdapter extends CompositeObjectSinkAdapter {
 
+    public AsyncCompositeObjectSinkAdapter() {
+    }
+
     public AsyncCompositeObjectSinkAdapter( RuleBasePartitionId partitionId, int alphaNodeHashingThreshold ) {
         super(partitionId, alphaNodeHashingThreshold );
     }
@@ -42,7 +45,7 @@
             sink.assertObject( factHandle, context, workingMemory );
         } else {
             // different partition, so use asynchronous propagation
-            PartitionTaskManager manager = workingMemory.getPartitionManager( this.partitionId );
+            PartitionTaskManager manager = workingMemory.getPartitionManager( sink.getPartitionId() );
             manager.enqueue( new PartitionTaskManager.FactAssertAction(factHandle, context, sink ) );
         }
     }