[jboss-svn-commits] JBL Code SVN: r23788 - labs/jbossrules/trunk/drools-compiler/src/test/java/org/drools/integrationtests.
jboss-svn-commits at lists.jboss.org
jboss-svn-commits at lists.jboss.org
Sun Nov 9 02:02:42 EST 2008
Author: mark.proctor at jboss.com
Date: 2008-11-09 02:02:41 -0500 (Sun, 09 Nov 2008)
New Revision: 23788
Modified:
labs/jbossrules/trunk/drools-compiler/src/test/java/org/drools/integrationtests/StatefulSessionTest.java
Log:
JBRULES-1734 Drools API
-reverted StatefulSessionTest
Modified: labs/jbossrules/trunk/drools-compiler/src/test/java/org/drools/integrationtests/StatefulSessionTest.java
===================================================================
--- labs/jbossrules/trunk/drools-compiler/src/test/java/org/drools/integrationtests/StatefulSessionTest.java 2008-11-09 06:58:51 UTC (rev 23787)
+++ labs/jbossrules/trunk/drools-compiler/src/test/java/org/drools/integrationtests/StatefulSessionTest.java 2008-11-09 07:02:41 UTC (rev 23788)
@@ -1,33 +1,37 @@
package org.drools.integrationtests;
-import java.io.InputStreamReader;
-import java.util.ArrayList;
-import java.util.Collection;
-import java.util.List;
-import java.util.concurrent.ExecutionException;
-import java.util.concurrent.Future;
-
import junit.framework.TestCase;
-
import org.drools.Cheese;
import org.drools.FactHandle;
-import org.drools.KnowledgeBase;
-import org.drools.KnowledgeBaseFactory;
+import org.drools.RuleBase;
import org.drools.RuleBaseConfiguration;
-import org.drools.builder.KnowledgeBuilder;
-import org.drools.builder.KnowledgeBuilderFactory;
-import org.drools.definition.KnowledgePackage;
-import org.drools.runtime.StatefulKnowledgeSession;
+import org.drools.RuleBaseFactory;
+import org.drools.StatefulSession;
+import org.drools.compiler.PackageBuilder;
+import org.drools.concurrent.Future;
+import org.drools.rule.Package;
+import java.io.InputStreamReader;
+import java.util.ArrayList;
+import java.util.List;
+
public class StatefulSessionTest extends TestCase {
final List list = new ArrayList();
- protected KnowledgeBase getKnowledgeBase() throws Exception {
- return KnowledgeBaseFactory.newKnowledgeBase();
+ protected RuleBase getRuleBase() throws Exception {
+
+ return RuleBaseFactory.newRuleBase( RuleBase.RETEOO,
+ null );
}
+ protected RuleBase getRuleBase(final RuleBaseConfiguration config) throws Exception {
+
+ return RuleBaseFactory.newRuleBase( RuleBase.RETEOO,
+ config );
+ }
+
public void testSingleObjectAssert() throws Exception {
- StatefulKnowledgeSession session = getSession();
+ StatefulSession session = getSession();
final Cheese stilton = new Cheese( "stilton",
5 );
@@ -43,14 +47,14 @@
}
}
- assertTrue( futureAssert.get() instanceof FactHandle );
+ assertTrue( futureAssert.getObject() instanceof FactHandle );
assertEquals( "stilton",
list.get( 0 ) );
}
public void testArrayObjectAssert() throws Exception {
- StatefulKnowledgeSession session = getSession();
+ StatefulSession session = getSession();
final Cheese stilton = new Cheese( "stilton",
5 );
@@ -67,15 +71,15 @@
}
- assertTrue( futureAssert.get() instanceof List );
- assertTrue( ((List)futureAssert.get()).get( 0 ) instanceof FactHandle );
+ assertTrue( futureAssert.getObject() instanceof List );
+ assertTrue( ((List)futureAssert.getObject()).get( 0 ) instanceof FactHandle );
assertEquals( "stilton",
list.get( 0 ) );
}
public void testCollectionObjectAssert() throws Exception {
- StatefulKnowledgeSession session = getSession();
+ StatefulSession session = getSession();
final Cheese stilton = new Cheese( "stilton",
5 );
@@ -93,8 +97,8 @@
}
}
- assertTrue( futureAssert.get() instanceof List );
- assertTrue( ((List)futureAssert.get()).get( 0 ) instanceof FactHandle );
+ assertTrue( futureAssert.getObject() instanceof List );
+ assertTrue( ((List)futureAssert.getObject()).get( 0 ) instanceof FactHandle );
assertEquals( "stilton",
list.get( 0 ) );
@@ -102,7 +106,7 @@
public void testHasExceptionSingleAssert()throws Exception {
- StatefulKnowledgeSession session = getExceptionSession();
+ StatefulSession session = getExceptionSession();
final Cheese brie = new Cheese( "brie",
12 );
@@ -117,19 +121,16 @@
fail( "Future should have finished by now" );
}
}
-
- assertTrue( futureAssert.get() instanceof FactHandle );
- try {
- futureFireAllRules.get();
- fail( "Exception Should have been thrown" );
- } catch ( ExecutionException e ) {
- // pass
- }
+
+
+ assertTrue( futureAssert.getObject() instanceof FactHandle );
+ assertTrue( futureFireAllRules.exceptionThrown() );
+ assertTrue( futureFireAllRules.getException() instanceof Exception );
}
public void testHasExceptionArrayAssert()throws Exception {
- StatefulKnowledgeSession session = getExceptionSession();
+ StatefulSession session = getExceptionSession();
final Cheese brie = new Cheese( "brie",
12 );
@@ -145,19 +146,14 @@
}
}
- assertTrue( futureAssert.get() instanceof List );
- assertTrue( ((List)futureAssert.get()).get( 0 ) instanceof FactHandle );
- try {
- futureFireAllRules.get();
- fail( "Exception Should have been thrown" );
- } catch ( ExecutionException e ) {
- //pass
- }
+ assertTrue( futureAssert.getObject() instanceof List );
+ assertTrue( ((List)futureAssert.getObject()).get( 0 ) instanceof FactHandle );
+ assertTrue( futureFireAllRules.getException() instanceof Exception );
}
public void testHasExceptionCollectionAssert()throws Exception {
- StatefulKnowledgeSession session = getExceptionSession();
+ StatefulSession session = getExceptionSession();
final Cheese brie = new Cheese( "brie",
12 );
@@ -175,50 +171,46 @@
}
}
- assertTrue( futureAssert.get() instanceof List );
- assertTrue( ((List)futureAssert.get()).get( 0 ) instanceof FactHandle );
- try {
- futureFireAllRules.get();
- fail( "Exception Should have been thrown" );
- } catch ( ExecutionException e ) {
- //pass
- }
+ assertTrue( futureAssert.getObject() instanceof List );
+ assertTrue( ((List)futureAssert.getObject()).get( 0 ) instanceof FactHandle );
+ assertTrue( futureFireAllRules.getException() instanceof Exception );
}
public void testSequentialException() {
RuleBaseConfiguration config = new RuleBaseConfiguration();
config.setSequential( true );
- KnowledgeBase kbase = KnowledgeBaseFactory.newKnowledgeBase( config );
+ RuleBase ruleBase = RuleBaseFactory.newRuleBase( config );
try {
- kbase.newStatefulKnowledgeSession();
+ ruleBase.newStatefulSession();
fail("cannot have a stateful session with sequential set to true" );
} catch ( Exception e ) {
}
}
- private StatefulKnowledgeSession getExceptionSession() throws Exception {
- KnowledgeBuilder kbuilder = KnowledgeBuilderFactory.newKnowledgeBuilder();
- kbuilder.addPackageFromDrl( new InputStreamReader( getClass().getResourceAsStream( "test_ConsequenceException.drl" ) ) );
- final Collection<KnowledgePackage> pkgs = kbuilder.getKnowledgePackages();
+ private StatefulSession getExceptionSession() throws Exception {
+ final PackageBuilder builder = new PackageBuilder();
+ builder.addPackageFromDrl( new InputStreamReader( getClass().getResourceAsStream( "test_ConsequenceException.drl" ) ) );
+ final Package pkg = builder.getPackage();
- KnowledgeBase kbase = getKnowledgeBase();
- kbase.addKnowledgePackages( pkgs );
- kbase = SerializationHelper.serializeObject( kbase );
- return kbase.newStatefulKnowledgeSession();
+ RuleBase ruleBase = getRuleBase();
+ ruleBase.addPackage( pkg );
+ ruleBase = SerializationHelper.serializeObject(ruleBase);
+ return ruleBase.newStatefulSession();
}
- private StatefulKnowledgeSession getSession() throws Exception {
- KnowledgeBuilder kbuilder = KnowledgeBuilderFactory.newKnowledgeBuilder();
- kbuilder.addPackageFromDrl( new InputStreamReader( getClass().getResourceAsStream( "literal_rule_test.drl" ) ) );
- final Collection<KnowledgePackage> pkgs = kbuilder.getKnowledgePackages();
+ private StatefulSession getSession() throws Exception {
+ final PackageBuilder builder = new PackageBuilder();
+ builder.addPackageFromDrl( new InputStreamReader( getClass().getResourceAsStream( "literal_rule_test.drl" ) ) );
+ final Package pkg = builder.getPackage();
- KnowledgeBase kbase = getKnowledgeBase();
- kbase.addKnowledgePackages( pkgs );
- kbase = SerializationHelper.serializeObject( kbase );
- StatefulKnowledgeSession session = kbase.newStatefulKnowledgeSession();
+ RuleBase ruleBase = getRuleBase();
+ ruleBase.addPackage( pkg );
+ ruleBase = SerializationHelper.serializeObject(ruleBase);
+ StatefulSession session = ruleBase.newStatefulSession();
+// session = SerializationHelper.serializeObject(session);
session.setGlobal( "list",
this.list );
return session;
More information about the jboss-svn-commits
mailing list