[jboss-svn-commits] JBL Code SVN: r24643 - in labs/jbossrules/trunk: drools-core/src/main/java/org/drools/runtime/pipeline/impl and 1 other directories.
jboss-svn-commits at lists.jboss.org
jboss-svn-commits at lists.jboss.org
Fri Jan 9 23:47:18 EST 2009
Author: mark.proctor at jboss.com
Date: 2009-01-09 23:47:18 -0500 (Fri, 09 Jan 2009)
New Revision: 24643
Added:
labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/StatefulKnowledgeSessionPipelineImpl.java
labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/StatefulKnowledgeSessionSetGlobalStage.java
labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/StatefulKnowledgeSessionSignalEventStage.java
Removed:
labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/StatefulKnowledgeSessionInsertPipelineImpl.java
Modified:
labs/jbossrules/trunk/drools-compiler/src/test/java/org/drools/integrationtests/StatefulKnowledgeSessionPipelineTest.java
labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/StatefulKnowledgeSessionInsertStage.java
labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/StatefulKnowledgeSessionPipelineContextImpl.java
labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/StatefulKnowledgeSessionStartProcessStage.java
labs/jbossrules/trunk/drools-core/src/test/java/org/drools/runtime/pipeline/impl/StatefulKnowledgeSessionPipelineTest.java
Log:
JBRULES-1903 Pipeline support for DataLoaders and Feeders
-Added support for startProcess, signalEvent and setGlobals
Modified: labs/jbossrules/trunk/drools-compiler/src/test/java/org/drools/integrationtests/StatefulKnowledgeSessionPipelineTest.java
===================================================================
--- labs/jbossrules/trunk/drools-compiler/src/test/java/org/drools/integrationtests/StatefulKnowledgeSessionPipelineTest.java 2009-01-09 19:28:59 UTC (rev 24642)
+++ labs/jbossrules/trunk/drools-compiler/src/test/java/org/drools/integrationtests/StatefulKnowledgeSessionPipelineTest.java 2009-01-10 04:47:18 UTC (rev 24643)
@@ -1,14 +1,42 @@
package org.drools.integrationtests;
+import java.io.Reader;
+import java.io.StringReader;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.Iterator;
+import java.util.List;
import java.util.Map;
import org.drools.KnowledgeBase;
import org.drools.KnowledgeBaseFactory;
+import org.drools.Message;
+import org.drools.RuleBase;
+import org.drools.RuleBaseFactory;
+import org.drools.StatefulSession;
+import org.drools.WorkingMemory;
+import org.drools.builder.KnowledgeBuilder;
+import org.drools.builder.KnowledgeBuilderError;
+import org.drools.builder.KnowledgeBuilderErrors;
+import org.drools.builder.KnowledgeBuilderFactory;
+import org.drools.builder.ResourceType;
+import org.drools.compiler.DroolsError;
+import org.drools.compiler.PackageBuilder;
+import org.drools.compiler.PackageBuilderErrors;
+import org.drools.io.ResourceFactory;
+import org.drools.process.core.context.variable.VariableScope;
+import org.drools.process.instance.ProcessInstance;
+import org.drools.process.instance.context.variable.VariableScopeInstance;
+import org.drools.rule.Package;
+import org.drools.runtime.ObjectFilter;
import org.drools.runtime.StatefulKnowledgeSession;
import org.drools.runtime.pipeline.ResultHandler;
import org.drools.runtime.pipeline.impl.MvelAction;
-import org.drools.runtime.pipeline.impl.StatefulKnowledgeSessionInsertPipelineImpl;
+import org.drools.runtime.pipeline.impl.StatefulKnowledgeSessionPipelineImpl;
import org.drools.runtime.pipeline.impl.StatefulKnowledgeSessionInsertStage;
+import org.drools.runtime.pipeline.impl.StatefulKnowledgeSessionSetGlobalStage;
+import org.drools.runtime.pipeline.impl.StatefulKnowledgeSessionSignalEventStage;
+import org.drools.runtime.pipeline.impl.StatefulKnowledgeSessionStartProcessStage;
import junit.framework.TestCase;
@@ -21,7 +49,7 @@
MvelAction mvelAction = new MvelAction( "context.resultHandler.handleResult( context.handles )");
stage1.setReceiver( mvelAction );
- StatefulKnowledgeSessionInsertPipelineImpl pipeline = new StatefulKnowledgeSessionInsertPipelineImpl(ksession);
+ StatefulKnowledgeSessionPipelineImpl pipeline = new StatefulKnowledgeSessionPipelineImpl(ksession);
pipeline.setReceiver( stage1 );
assertEquals( 0, ksession.getObjects().size() );
@@ -32,6 +60,157 @@
assertEquals( 1, resultHanadle.getHandles().size() );
}
+ public void testStartProcess() {
+ // This also tests setGlobal
+ KnowledgeBuilder kbuilder = KnowledgeBuilderFactory.newKnowledgeBuilder();
+
+ Reader source = new StringReader(
+ "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n" +
+ "<process xmlns=\"http://drools.org/drools-5.0/process\"\n" +
+ " xmlns:xs=\"http://www.w3.org/2001/XMLSchema-instance\"\n" +
+ " xs:schemaLocation=\"http://drools.org/drools-5.0/process drools-processes-5.0.xsd\"\n" +
+ " type=\"RuleFlow\" name=\"flow\" id=\"org.drools.actions\" package-name=\"org.drools\" version=\"1\" >\n" +
+ "\n" +
+ " <header>\n" +
+ " <globals>\n" +
+ " <global identifier=\"list\" type=\"java.util.List\" />\n" +
+ " </globals>\n" +
+ " </header>\n" +
+ "\n" +
+ " <nodes>\n" +
+ " <start id=\"1\" name=\"Start\" />\n" +
+ " <actionNode id=\"2\" name=\"MyActionNode\" >\n" +
+ " <action type=\"expression\" dialect=\"java\" >" +
+ " String variable = (String) context.getVariable(\"variable\");\n" +
+ " list.add(variable);\n" +
+ " </action>\n" +
+ " </actionNode>\n" +
+ " <end id=\"3\" name=\"End\" />\n" +
+ " </nodes>\n" +
+ "\n" +
+ " <connections>\n" +
+ " <connection from=\"1\" to=\"2\" />\n" +
+ " <connection from=\"2\" to=\"3\" />\n" +
+ " </connections>\n" +
+ "\n" +
+ "</process>");
+
+ kbuilder.add( ResourceFactory.newReaderResource( source ), ResourceType.DRF );
+ KnowledgeBuilderErrors errors = kbuilder.getErrors();
+ if (!errors.isEmpty()) {
+ for (KnowledgeBuilderError error: errors) {
+ System.err.println(error);
+ }
+ fail("Errors while building package");
+ }
+
+ KnowledgeBase kbase = KnowledgeBaseFactory.newKnowledgeBase();
+ kbase.addKnowledgePackages( kbuilder.getKnowledgePackages() );
+
+ StatefulKnowledgeSession ksession = kbase.newStatefulKnowledgeSession();
+ List<String> list = new ArrayList<String>();
+ Map globals = new HashMap();
+ globals.put("list", list);
+
+ StatefulKnowledgeSessionSetGlobalStage setGlobal = new StatefulKnowledgeSessionSetGlobalStage();
+ StatefulKnowledgeSessionPipelineImpl pipeline = new StatefulKnowledgeSessionPipelineImpl(ksession);
+ pipeline.setReceiver( setGlobal );
+ pipeline.insert( globals, null );
+
+ Map vars = new HashMap();
+ vars.put( "variable", "SomeText" );
+
+ StatefulKnowledgeSessionStartProcessStage startProcess = new StatefulKnowledgeSessionStartProcessStage("org.drools.actions");
+ pipeline = new StatefulKnowledgeSessionPipelineImpl(ksession);
+ pipeline.setReceiver( startProcess );
+ pipeline.insert( vars, null );
+
+ assertEquals(1, list.size());
+ assertEquals("SomeText", list.get(0));
+ }
+
+ public void testSignalEvent() throws Exception {
+ KnowledgeBuilder kbuilder = KnowledgeBuilderFactory.newKnowledgeBuilder();
+ Reader source = new StringReader(
+ "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n" +
+ "<process xmlns=\"http://drools.org/drools-5.0/process\"\n" +
+ " xmlns:xs=\"http://www.w3.org/2001/XMLSchema-instance\"\n" +
+ " xs:schemaLocation=\"http://drools.org/drools-5.0/process drools-processes-5.0.xsd\"\n" +
+ " type=\"RuleFlow\" name=\"flow\" id=\"org.drools.event\" package-name=\"org.drools\" version=\"1\" >\n" +
+ "\n" +
+ " <header>\n" +
+ " <globals>\n" +
+ " <global identifier=\"list\" type=\"java.util.List\" />\n" +
+ " </globals>\n" +
+ " <variables>\n" +
+ " <variable name=\"MyVar\" >\n" +
+ " <type name=\"org.drools.process.core.datatype.impl.type.StringDataType\" />\n" +
+ " <value>SomeText</value>\n" +
+ " </variable>\n" +
+ " </variables>\n" +
+ " </header>\n" +
+ "\n" +
+ " <nodes>\n" +
+ " <start id=\"1\" name=\"Start\" />\n" +
+ " <eventNode id=\"2\" name=\"Event\" variableName=\"MyVar\" >\n" +
+ " <eventFilters>\n" +
+ " <eventFilter type=\"eventType\" eventType=\"MyEvent\" />\n" +
+ " </eventFilters>\n" +
+ " </eventNode>\n" +
+ " <actionNode id=\"3\" name=\"MyActionNode\" >\n" +
+ " <action type=\"expression\" dialect=\"java\" >" +
+ " String variable = (String) context.getVariable(\"MyVar\");\n" +
+ " list.add(variable);\n" +
+ " </action>\n" +
+ " </actionNode>\n" +
+ " <join id=\"4\" name=\"Join\" type=\"1\" />\n" +
+ " <end id=\"5\" name=\"End\" />\n" +
+ " </nodes>\n" +
+ "\n" +
+ " <connections>\n" +
+ " <connection from=\"1\" to=\"4\" />\n" +
+ " <connection from=\"2\" to=\"3\" />\n" +
+ " <connection from=\"3\" to=\"4\" />\n" +
+ " <connection from=\"4\" to=\"5\" />\n" +
+ " </connections>\n" +
+ "\n" +
+ "</process>");
+ kbuilder.add( ResourceFactory.newReaderResource( source ), ResourceType.DRF );
+ KnowledgeBuilderErrors errors = kbuilder.getErrors();
+ if (!errors.isEmpty()) {
+ for (KnowledgeBuilderError error: errors) {
+ System.err.println(error);
+ }
+ fail("Errors while building package");
+ }
+
+ KnowledgeBase kbase = KnowledgeBaseFactory.newKnowledgeBase();
+ kbase.addKnowledgePackages( kbuilder.getKnowledgePackages() );
+
+ StatefulKnowledgeSession ksession = kbase.newStatefulKnowledgeSession();
+ List<String> list = new ArrayList<String>();
+ Map globals = new HashMap();
+ globals.put("list", list);
+
+ StatefulKnowledgeSessionSetGlobalStage setGlobal = new StatefulKnowledgeSessionSetGlobalStage();
+ StatefulKnowledgeSessionPipelineImpl pipeline = new StatefulKnowledgeSessionPipelineImpl(ksession);
+ pipeline.setReceiver( setGlobal );
+ pipeline.insert( globals, null );
+
+ org.drools.runtime.process.ProcessInstance instance = ksession.startProcess("org.drools.event");
+
+ StatefulKnowledgeSessionSignalEventStage signalEvent = new StatefulKnowledgeSessionSignalEventStage( "MyEvent",
+ instance.getId());
+ pipeline = new StatefulKnowledgeSessionPipelineImpl(ksession);
+ pipeline.setReceiver( signalEvent );
+
+ pipeline.insert( "MyValue", null );
+
+ assertEquals(1, list.size());
+ assertEquals("MyValue", list.get(0));
+
+ }
+
public static class ResultHandlerImpl implements ResultHandler {
Map handles;
public void handleResult(Object object) {
Deleted: labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/StatefulKnowledgeSessionInsertPipelineImpl.java
===================================================================
--- labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/StatefulKnowledgeSessionInsertPipelineImpl.java 2009-01-09 19:28:59 UTC (rev 24642)
+++ labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/StatefulKnowledgeSessionInsertPipelineImpl.java 2009-01-10 04:47:18 UTC (rev 24643)
@@ -1,30 +0,0 @@
-package org.drools.runtime.pipeline.impl;
-
-import org.drools.runtime.StatefulKnowledgeSession;
-import org.drools.runtime.dataloader.impl.EntryPointPipelineContext;
-import org.drools.runtime.pipeline.Receiver;
-import org.drools.runtime.pipeline.ResultHandler;
-import org.drools.runtime.rule.WorkingMemoryEntryPoint;
-
-public class StatefulKnowledgeSessionInsertPipelineImpl extends BaseEmitter
- implements
- Pipeline {
- private WorkingMemoryEntryPoint entryPoint;
-
- public StatefulKnowledgeSessionInsertPipelineImpl(StatefulKnowledgeSession ksession,
- String entryPointName) {
- this.entryPoint = ksession.getWorkingMemoryEntryPoint( entryPointName );
- }
-
- public StatefulKnowledgeSessionInsertPipelineImpl(StatefulKnowledgeSession ksession) {
- this.entryPoint = ksession;
- }
-
- public void insert(Object object,
- ResultHandler resultHandler) {
- EntryPointPipelineContext context = new EntryPointPipelineContext( this.entryPoint,
- resultHandler );
- emit( object, context );
- }
-
-}
Modified: labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/StatefulKnowledgeSessionInsertStage.java
===================================================================
--- labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/StatefulKnowledgeSessionInsertStage.java 2009-01-09 19:28:59 UTC (rev 24642)
+++ labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/StatefulKnowledgeSessionInsertStage.java 2009-01-10 04:47:18 UTC (rev 24643)
@@ -1,21 +1,24 @@
package org.drools.runtime.pipeline.impl;
import org.drools.common.InternalFactHandle;
-import org.drools.runtime.dataloader.impl.EntryPointPipelineContext;
import org.drools.runtime.pipeline.PipelineContext;
import org.drools.runtime.pipeline.Receiver;
import org.drools.runtime.rule.FactHandle;
-public class StatefulKnowledgeSessionInsertStage extends BaseEmitter implements Receiver {
+public class StatefulKnowledgeSessionInsertStage extends BaseEmitter
+ implements
+ Receiver {
public void receive(Object object,
PipelineContext context) {
- EntryPointPipelineContext epContext = ( EntryPointPipelineContext ) context;
- FactHandle handle = epContext.getEntryPoint().insert( object );
-
- epContext.getHandles().put( handle, (( InternalFactHandle ) handle ).getObject() );
-
- emit( object, epContext );
+ StatefulKnowledgeSessionPipelineContextImpl kContext = (StatefulKnowledgeSessionPipelineContextImpl) context;
+ FactHandle handle = kContext.getEntryPoint().insert( object );
+
+ kContext.getHandles().put( handle,
+ ((InternalFactHandle) handle).getObject() );
+
+ emit( object,
+ kContext );
}
}
Modified: labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/StatefulKnowledgeSessionPipelineContextImpl.java
===================================================================
--- labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/StatefulKnowledgeSessionPipelineContextImpl.java 2009-01-09 19:28:59 UTC (rev 24642)
+++ labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/StatefulKnowledgeSessionPipelineContextImpl.java 2009-01-10 04:47:18 UTC (rev 24643)
@@ -1,5 +1,9 @@
package org.drools.runtime.pipeline.impl;
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.Map;
+
import org.drools.runtime.StatefulKnowledgeSession;
import org.drools.runtime.pipeline.ResultHandler;
import org.drools.runtime.pipeline.StatefulKnowledgeSessionPipelineContext;
@@ -8,13 +12,14 @@
public class StatefulKnowledgeSessionPipelineContextImpl extends BasePipelineContext
implements
StatefulKnowledgeSessionPipelineContext {
+ private Map handles;
private StatefulKnowledgeSession ksession;
private WorkingMemoryEntryPoint entryPoint;
public StatefulKnowledgeSessionPipelineContextImpl(StatefulKnowledgeSession ksession,
- ClassLoader classLoader,
WorkingMemoryEntryPoint entryPoint,
- ResultHandler resultHandler) {
+ ResultHandler resultHandler,
+ ClassLoader classLoader) {
super( classLoader,
resultHandler );
this.ksession = ksession;
@@ -28,5 +33,12 @@
public WorkingMemoryEntryPoint getEntryPoint() {
return entryPoint;
}
+
+ public Map getHandles() {
+ if ( handles == null ) {
+ this.handles = new HashMap();
+ }
+ return handles;
+ }
}
Copied: labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/StatefulKnowledgeSessionPipelineImpl.java (from rev 24596, labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/StatefulKnowledgeSessionInsertPipelineImpl.java)
===================================================================
--- labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/StatefulKnowledgeSessionPipelineImpl.java (rev 0)
+++ labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/StatefulKnowledgeSessionPipelineImpl.java 2009-01-10 04:47:18 UTC (rev 24643)
@@ -0,0 +1,39 @@
+package org.drools.runtime.pipeline.impl;
+
+import org.drools.common.InternalRuleBase;
+import org.drools.impl.StatefulKnowledgeSessionImpl;
+import org.drools.runtime.StatefulKnowledgeSession;
+import org.drools.runtime.pipeline.ResultHandler;
+import org.drools.runtime.rule.WorkingMemoryEntryPoint;
+
+public class StatefulKnowledgeSessionPipelineImpl extends BaseEmitter
+ implements
+ Pipeline {
+ private StatefulKnowledgeSession ksession;
+ private WorkingMemoryEntryPoint entryPoint;
+
+
+ public StatefulKnowledgeSessionPipelineImpl(StatefulKnowledgeSession ksession) {
+ this.ksession = ksession;
+ this.entryPoint = ksession;
+ }
+
+ public StatefulKnowledgeSessionPipelineImpl(StatefulKnowledgeSession ksession,
+ String entryPointName) {
+ this.ksession = ksession;
+ this.entryPoint = ksession.getWorkingMemoryEntryPoint( entryPointName );
+ }
+
+ public void insert(Object object,
+ ResultHandler resultHandler) {
+ ClassLoader cl = ((InternalRuleBase) ((StatefulKnowledgeSessionImpl) this.ksession).getRuleBase()).getRootClassLoader();
+
+ StatefulKnowledgeSessionPipelineContextImpl context = new StatefulKnowledgeSessionPipelineContextImpl( this.ksession,
+ this.entryPoint,
+ resultHandler,
+ cl );
+ emit( object,
+ context );
+ }
+
+}
Property changes on: labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/StatefulKnowledgeSessionPipelineImpl.java
___________________________________________________________________
Name: svn:mergeinfo
+
Added: labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/StatefulKnowledgeSessionSetGlobalStage.java
===================================================================
--- labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/StatefulKnowledgeSessionSetGlobalStage.java (rev 0)
+++ labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/StatefulKnowledgeSessionSetGlobalStage.java 2009-01-10 04:47:18 UTC (rev 24643)
@@ -0,0 +1,31 @@
+package org.drools.runtime.pipeline.impl;
+
+import java.util.Map;
+import java.util.Map.Entry;
+
+import org.drools.runtime.StatefulKnowledgeSession;
+import org.drools.runtime.pipeline.PipelineContext;
+import org.drools.runtime.pipeline.Receiver;
+import org.drools.runtime.pipeline.StatefulKnowledgeSessionPipelineContext;
+
+public class StatefulKnowledgeSessionSetGlobalStage extends BaseEmitter
+ implements
+ Receiver {
+
+ public StatefulKnowledgeSessionSetGlobalStage() {
+ }
+
+ public void receive(Object object,
+ PipelineContext context) {
+ StatefulKnowledgeSessionPipelineContext kContext = (StatefulKnowledgeSessionPipelineContext) context;
+ StatefulKnowledgeSession ksession = kContext.getStatefulKnowledgeSession();
+ Map<String, Object> vars = ( Map<String, Object> ) object;
+ for ( Entry<String, Object> entry : vars.entrySet()) {
+ ksession.setGlobal( entry.getKey(), entry.getValue() );
+ }
+
+ emit( object,
+ kContext );
+ }
+
+}
Added: labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/StatefulKnowledgeSessionSignalEventStage.java
===================================================================
--- labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/StatefulKnowledgeSessionSignalEventStage.java (rev 0)
+++ labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/StatefulKnowledgeSessionSignalEventStage.java 2009-01-10 04:47:18 UTC (rev 24643)
@@ -0,0 +1,29 @@
+package org.drools.runtime.pipeline.impl;
+
+import org.drools.runtime.pipeline.PipelineContext;
+import org.drools.runtime.pipeline.Receiver;
+import org.drools.runtime.pipeline.StatefulKnowledgeSessionPipelineContext;
+
+public class StatefulKnowledgeSessionSignalEventStage extends BaseEmitter
+ implements
+ Receiver {
+ private long id;
+ private String eventType;
+
+ public StatefulKnowledgeSessionSignalEventStage(String eventType,
+ long id) {
+ this.eventType = eventType;
+ this.id = id;
+ }
+
+ public void receive(Object object,
+ PipelineContext context) {
+ StatefulKnowledgeSessionPipelineContext kContext = (StatefulKnowledgeSessionPipelineContext) context;
+ kContext.getStatefulKnowledgeSession().getProcessInstance( this.id ).signalEvent( this.eventType,
+ object );
+
+ emit( object,
+ kContext );
+ }
+
+}
Modified: labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/StatefulKnowledgeSessionStartProcessStage.java
===================================================================
--- labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/StatefulKnowledgeSessionStartProcessStage.java 2009-01-09 19:28:59 UTC (rev 24642)
+++ labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/StatefulKnowledgeSessionStartProcessStage.java 2009-01-10 04:47:18 UTC (rev 24643)
@@ -6,7 +6,7 @@
import org.drools.runtime.pipeline.Receiver;
import org.drools.runtime.pipeline.StatefulKnowledgeSessionPipelineContext;
-public class StatefulKnowledgeSessionStartProcessStage extends BaseStage
+public class StatefulKnowledgeSessionStartProcessStage extends BaseEmitter
implements
Receiver {
private String id;
@@ -20,6 +20,8 @@
StatefulKnowledgeSessionPipelineContext kContext = (StatefulKnowledgeSessionPipelineContext) context;
kContext.getStatefulKnowledgeSession().startProcess( id,
(Map<String, Object>) object );
+ emit( object,
+ kContext );
}
}
Modified: labs/jbossrules/trunk/drools-core/src/test/java/org/drools/runtime/pipeline/impl/StatefulKnowledgeSessionPipelineTest.java
===================================================================
--- labs/jbossrules/trunk/drools-core/src/test/java/org/drools/runtime/pipeline/impl/StatefulKnowledgeSessionPipelineTest.java 2009-01-09 19:28:59 UTC (rev 24642)
+++ labs/jbossrules/trunk/drools-core/src/test/java/org/drools/runtime/pipeline/impl/StatefulKnowledgeSessionPipelineTest.java 2009-01-10 04:47:18 UTC (rev 24643)
@@ -18,7 +18,7 @@
MvelAction mvelAction = new MvelAction( "context.resultHandler.handleResult( context.handles )");
stage1.setReceiver( mvelAction );
- StatefulKnowledgeSessionInsertPipelineImpl pipeline = new StatefulKnowledgeSessionInsertPipelineImpl(ksession);
+ StatefulKnowledgeSessionPipelineImpl pipeline = new StatefulKnowledgeSessionPipelineImpl(ksession);
pipeline.setReceiver( stage1 );
assertEquals( 0, ksession.getObjects().size() );
More information about the jboss-svn-commits
mailing list