[jboss-svn-commits] JBL Code SVN: r33981 - labs/jbossrules/trunk/drools-pipeline/src/test/java/org/drools/runtime/pipeline/impl.
jboss-svn-commits at lists.jboss.org
jboss-svn-commits at lists.jboss.org
Fri Jul 16 23:58:53 EDT 2010
Author: mark.proctor at jboss.com
Date: 2010-07-16 23:58:52 -0400 (Fri, 16 Jul 2010)
New Revision: 33981
Added:
labs/jbossrules/trunk/drools-pipeline/src/test/java/org/drools/runtime/pipeline/impl/CallableTest.java
labs/jbossrules/trunk/drools-pipeline/src/test/java/org/drools/runtime/pipeline/impl/IterateSplitterTest.java
labs/jbossrules/trunk/drools-pipeline/src/test/java/org/drools/runtime/pipeline/impl/ListAdapterTest.java
labs/jbossrules/trunk/drools-pipeline/src/test/java/org/drools/runtime/pipeline/impl/MvelActionTest.java
labs/jbossrules/trunk/drools-pipeline/src/test/java/org/drools/runtime/pipeline/impl/MvelExpressionTest.java
labs/jbossrules/trunk/drools-pipeline/src/test/java/org/drools/runtime/pipeline/impl/StatefulKnowledgeSessionPipelineTest.java
Log:
JBRULES-2347 Camel
-merging all the pipelien modules, to simplify the build, as they are only kept around now for legacy users.
Copied: labs/jbossrules/trunk/drools-pipeline/src/test/java/org/drools/runtime/pipeline/impl/CallableTest.java (from rev 33978, labs/jbossrules/trunk/drools-core/src/test/java/org/drools/runtime/pipeline/impl/CallableTest.java)
===================================================================
--- labs/jbossrules/trunk/drools-pipeline/src/test/java/org/drools/runtime/pipeline/impl/CallableTest.java (rev 0)
+++ labs/jbossrules/trunk/drools-pipeline/src/test/java/org/drools/runtime/pipeline/impl/CallableTest.java 2010-07-17 03:58:52 UTC (rev 33981)
@@ -0,0 +1,34 @@
+package org.drools.runtime.pipeline.impl;
+
+import junit.framework.TestCase;
+
+import org.drools.runtime.pipeline.Action;
+import org.drools.runtime.pipeline.Callable;
+import org.drools.runtime.pipeline.PipelineFactory;
+
+public class CallableTest extends TestCase {
+ public void testCallable() {
+ MockClass mock = new MockClass();
+ Callable callable = new CallableImpl();
+ Action action = PipelineFactory.newMvelAction( "this.set = true" );
+ callable.setReceiver( action );
+ action.setReceiver( callable );
+ assertFalse( mock.isSet() );
+ callable.call( mock,
+ new BasePipelineContext( Thread.currentThread().getContextClassLoader() ) );
+ assertTrue( mock.isSet() );
+ }
+
+ public static class MockClass {
+ private boolean set;
+
+ public boolean isSet() {
+ return set;
+ }
+
+ public void setSet(boolean set) {
+ this.set = set;
+ }
+
+ }
+}
Copied: labs/jbossrules/trunk/drools-pipeline/src/test/java/org/drools/runtime/pipeline/impl/IterateSplitterTest.java (from rev 33978, labs/jbossrules/trunk/drools-core/src/test/java/org/drools/runtime/pipeline/impl/IterateSplitterTest.java)
===================================================================
--- labs/jbossrules/trunk/drools-pipeline/src/test/java/org/drools/runtime/pipeline/impl/IterateSplitterTest.java (rev 0)
+++ labs/jbossrules/trunk/drools-pipeline/src/test/java/org/drools/runtime/pipeline/impl/IterateSplitterTest.java 2010-07-17 03:58:52 UTC (rev 33981)
@@ -0,0 +1,53 @@
+package org.drools.runtime.pipeline.impl;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import org.drools.runtime.pipeline.Action;
+import org.drools.runtime.pipeline.Callable;
+import org.drools.runtime.pipeline.Expression;
+import org.drools.runtime.pipeline.ListAdapter;
+import org.drools.runtime.pipeline.PipelineFactory;
+import org.drools.runtime.pipeline.Splitter;
+import org.mvel2.MVEL;
+import org.mvel2.optimizers.OptimizerFactory;
+
+import junit.framework.TestCase;
+
+public class IterateSplitterTest extends TestCase {
+ public void testSplitter() {
+ MockClass mock = new MockClass();
+ List<Integer> list = new ArrayList<Integer>();
+
+ Action action = PipelineFactory.newMvelAction( "this.setValues( [0, 1, 2, 3, 4] ) " );
+ Expression expr = PipelineFactory.newMvelExpression( "this.values" );
+ action.setReceiver( expr );
+
+ Splitter splitter = PipelineFactory.newIterateSplitter();
+ expr.setReceiver( splitter );
+
+ ListAdapter listAdapter = new ListAdapterImpl( list, true );
+ splitter.setReceiver( listAdapter );
+
+ assertNull( mock.getValues() );
+ action.receive( mock, new BasePipelineContext( Thread.currentThread().getContextClassLoader() ) );
+
+
+ System.out.println( list.get( 0 ));
+ assertEquals( 5, list.size());
+ assertEquals( 0,list.get( 0 ).intValue() );
+ assertEquals( 4,list.get( 4 ).intValue() );
+ }
+
+ public static class MockClass {
+ private List values;
+
+ public List getValues() {
+ return values;
+ }
+
+ public void setValues(List values) {
+ this.values = values;
+ }
+ }
+}
Copied: labs/jbossrules/trunk/drools-pipeline/src/test/java/org/drools/runtime/pipeline/impl/ListAdapterTest.java (from rev 33978, labs/jbossrules/trunk/drools-core/src/test/java/org/drools/runtime/pipeline/impl/ListAdapterTest.java)
===================================================================
--- labs/jbossrules/trunk/drools-pipeline/src/test/java/org/drools/runtime/pipeline/impl/ListAdapterTest.java (rev 0)
+++ labs/jbossrules/trunk/drools-pipeline/src/test/java/org/drools/runtime/pipeline/impl/ListAdapterTest.java 2010-07-17 03:58:52 UTC (rev 33981)
@@ -0,0 +1,44 @@
+package org.drools.runtime.pipeline.impl;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import org.drools.runtime.pipeline.Action;
+import org.drools.runtime.pipeline.Callable;
+import org.drools.runtime.pipeline.Expression;
+import org.drools.runtime.pipeline.ListAdapter;
+import org.drools.runtime.pipeline.PipelineFactory;
+
+import junit.framework.TestCase;
+
+public class ListAdapterTest extends TestCase {
+ public void testListAdapter() {
+ MockClass mock = new MockClass();
+ List list = new ArrayList();
+
+ Action action = PipelineFactory.newMvelAction( "this.set = true" );
+
+ ListAdapter listAdapter = new ListAdapterImpl( list, true );
+ action.setReceiver( listAdapter );
+
+ assertFalse( mock.isSet() );
+ action.receive( mock, new BasePipelineContext( Thread.currentThread().getContextClassLoader() ) );
+
+ assertEquals( 1, list.size());
+ assertSame( mock, list.get( 0 ) );
+ assertTrue( mock.isSet() );
+ }
+
+ public static class MockClass {
+ private boolean set;
+
+ public boolean isSet() {
+ return set;
+ }
+
+ public void setSet(boolean set) {
+ this.set = set;
+ }
+
+ }
+}
Copied: labs/jbossrules/trunk/drools-pipeline/src/test/java/org/drools/runtime/pipeline/impl/MvelActionTest.java (from rev 33978, labs/jbossrules/trunk/drools-core/src/test/java/org/drools/runtime/pipeline/impl/MvelActionTest.java)
===================================================================
--- labs/jbossrules/trunk/drools-pipeline/src/test/java/org/drools/runtime/pipeline/impl/MvelActionTest.java (rev 0)
+++ labs/jbossrules/trunk/drools-pipeline/src/test/java/org/drools/runtime/pipeline/impl/MvelActionTest.java 2010-07-17 03:58:52 UTC (rev 33981)
@@ -0,0 +1,45 @@
+package org.drools.runtime.pipeline.impl;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import org.drools.runtime.pipeline.Action;
+import org.drools.runtime.pipeline.Callable;
+import org.drools.runtime.pipeline.Expression;
+import org.drools.runtime.pipeline.ListAdapter;
+import org.drools.runtime.pipeline.PipelineFactory;
+import org.drools.runtime.pipeline.Splitter;
+import org.mvel2.MVEL;
+import org.mvel2.optimizers.OptimizerFactory;
+
+import junit.framework.TestCase;
+
+public class MvelActionTest extends TestCase {
+ public void testAction() {
+ MockClass mock = new MockClass();
+ List<Integer> list = new ArrayList<Integer>();
+
+ Action action = PipelineFactory.newMvelAction( "this.setValues( [0, 1, 2, 3, 4] ) " );
+
+ assertNull( mock.getValues() );
+ action.receive( mock, new BasePipelineContext( Thread.currentThread().getContextClassLoader() ) );
+
+
+ System.out.println( mock.getValues().get( 0 ));
+ assertEquals( 5, mock.getValues().size());
+ assertEquals( 0, mock.getValues().get( 0 ).intValue() );
+ assertEquals( 4, mock.getValues().get( 4 ).intValue() );
+ }
+
+ public static class MockClass {
+ private List<Integer> values;
+
+ public List<Integer> getValues() {
+ return values;
+ }
+
+ public void setValues(List<Integer> values) {
+ this.values = values;
+ }
+ }
+}
Copied: labs/jbossrules/trunk/drools-pipeline/src/test/java/org/drools/runtime/pipeline/impl/MvelExpressionTest.java (from rev 33978, labs/jbossrules/trunk/drools-core/src/test/java/org/drools/runtime/pipeline/impl/MvelExpressionTest.java)
===================================================================
--- labs/jbossrules/trunk/drools-pipeline/src/test/java/org/drools/runtime/pipeline/impl/MvelExpressionTest.java (rev 0)
+++ labs/jbossrules/trunk/drools-pipeline/src/test/java/org/drools/runtime/pipeline/impl/MvelExpressionTest.java 2010-07-17 03:58:52 UTC (rev 33981)
@@ -0,0 +1,49 @@
+package org.drools.runtime.pipeline.impl;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import org.drools.runtime.pipeline.Action;
+import org.drools.runtime.pipeline.Callable;
+import org.drools.runtime.pipeline.Expression;
+import org.drools.runtime.pipeline.ListAdapter;
+import org.drools.runtime.pipeline.PipelineFactory;
+import org.drools.runtime.pipeline.Splitter;
+import org.mvel2.MVEL;
+import org.mvel2.optimizers.OptimizerFactory;
+
+import junit.framework.TestCase;
+
+public class MvelExpressionTest extends TestCase {
+ public void testExpression() {
+ MockClass mock = new MockClass();
+
+ Callable callable = new CallableImpl();
+ Action action = PipelineFactory.newMvelAction( "this.setValues( [0, 1, 2, 3, 4] ) " );
+ callable.setReceiver( action );
+ Expression expr = PipelineFactory.newMvelExpression( "this.values" );
+ action.setReceiver( expr );
+ expr.setReceiver( callable );
+
+ assertNull( mock.getValues() );
+ List<Integer> list = ( List<Integer> ) callable.call( mock, new BasePipelineContext( Thread.currentThread().getContextClassLoader() ) );
+
+
+ System.out.println( list.get( 0 ));
+ assertEquals( 5, list.size());
+ assertEquals( 0,list.get( 0 ).intValue() );
+ assertEquals( 4,list.get( 4 ).intValue() );
+ }
+
+ public static class MockClass {
+ private List values;
+
+ public List getValues() {
+ return values;
+ }
+
+ public void setValues(List values) {
+ this.values = values;
+ }
+ }
+}
Copied: labs/jbossrules/trunk/drools-pipeline/src/test/java/org/drools/runtime/pipeline/impl/StatefulKnowledgeSessionPipelineTest.java (from rev 33978, labs/jbossrules/trunk/drools-core/src/test/java/org/drools/runtime/pipeline/impl/StatefulKnowledgeSessionPipelineTest.java)
===================================================================
--- labs/jbossrules/trunk/drools-pipeline/src/test/java/org/drools/runtime/pipeline/impl/StatefulKnowledgeSessionPipelineTest.java (rev 0)
+++ labs/jbossrules/trunk/drools-pipeline/src/test/java/org/drools/runtime/pipeline/impl/StatefulKnowledgeSessionPipelineTest.java 2010-07-17 03:58:52 UTC (rev 33981)
@@ -0,0 +1,47 @@
+package org.drools.runtime.pipeline.impl;
+
+import java.util.Map;
+
+import org.drools.KnowledgeBase;
+import org.drools.KnowledgeBaseFactory;
+import org.drools.runtime.StatefulKnowledgeSession;
+import org.drools.runtime.pipeline.Action;
+import org.drools.runtime.pipeline.Pipeline;
+import org.drools.runtime.pipeline.PipelineFactory;
+import org.drools.runtime.pipeline.ResultHandler;
+
+import junit.framework.TestCase;
+
+public class StatefulKnowledgeSessionPipelineTest extends TestCase {
+ public void testInsertObject() {
+ KnowledgeBase kbase = KnowledgeBaseFactory.newKnowledgeBase();
+ StatefulKnowledgeSession ksession = kbase.newStatefulKnowledgeSession();
+
+ Action executeResultHandler = PipelineFactory.newExecuteResultHandler();
+
+ StatefulKnowledgeSessionInsertStage insertStage = new StatefulKnowledgeSessionInsertStage();
+ insertStage.setReceiver( executeResultHandler );
+
+
+ Pipeline pipeline = PipelineFactory.newStatefulKnowledgeSessionPipeline(ksession);
+ pipeline.setReceiver( insertStage );
+
+ assertEquals( 0, ksession.getObjects().size() );
+
+ ResultHandlerImpl resultHanadle = new ResultHandlerImpl();
+ pipeline.insert( "Hello", resultHanadle );
+
+ assertEquals( 1, resultHanadle.getHandles().size() );
+ }
+
+ public static class ResultHandlerImpl implements ResultHandler {
+ Map handles;
+ public void handleResult(Object object) {
+ this.handles = ( Map ) object;
+ }
+ public Map getHandles() {
+ return this.handles;
+ }
+
+ }
+}
More information about the jboss-svn-commits
mailing list