[jboss-svn-commits] JBL Code SVN: r18992 - labs/jbossrules/branches/ming-serialization/drools-compiler/src/test/java/org/drools/integrationtests.

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

Author: mingjin
Date: 2008-03-14 13:23:46 -0400 (Fri, 14 Mar 2008)
New Revision: 18992

Modified:
   labs/jbossrules/branches/ming-serialization/drools-compiler/src/test/java/org/drools/integrationtests/MultithreadTest.java
Log:
added more rulebase serialization

Modified: labs/jbossrules/branches/ming-serialization/drools-compiler/src/test/java/org/drools/integrationtests/MultithreadTest.java
===================================================================
--- labs/jbossrules/branches/ming-serialization/drools-compiler/src/test/java/org/drools/integrationtests/MultithreadTest.java	2008-03-14 17:15:16 UTC (rev 18991)
+++ labs/jbossrules/branches/ming-serialization/drools-compiler/src/test/java/org/drools/integrationtests/MultithreadTest.java	2008-03-14 17:23:46 UTC (rev 18992)
@@ -18,28 +18,23 @@
 
 package org.drools.integrationtests;
 
-import java.io.InputStreamReader;
-import java.io.StringReader;
-import java.util.ArrayList;
-import java.util.Collections;
-import java.util.List;
-import java.util.Queue;
-import java.util.Vector;
-import java.util.concurrent.ConcurrentLinkedQueue;
-
 import junit.framework.TestCase;
-
 import org.drools.Child;
 import org.drools.GrandParent;
 import org.drools.Order;
 import org.drools.Parent;
 import org.drools.RuleBase;
-import org.drools.RuleBaseConfiguration;
 import org.drools.RuleBaseFactory;
 import org.drools.StatefulSession;
 import org.drools.compiler.PackageBuilder;
-import org.drools.compiler.PackageBuilderConfiguration;
 
+import java.io.InputStreamReader;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Queue;
+import java.util.Vector;
+import java.util.concurrent.ConcurrentLinkedQueue;
+
 /**
  * This is a test case for multi-thred issues
  * 
@@ -73,6 +68,7 @@
             builder.addPackageFromDrl( new InputStreamReader( getClass().getResourceAsStream( "test_MultithreadRulebaseSharing.drl" ) ) );
             RuleBase ruleBase = RuleBaseFactory.newRuleBase();
             ruleBase.addPackage( builder.getPackage() );
+            ruleBase    = SerializationHelper.serializeObject(ruleBase);
             final Thread[] t = new Thread[THREAD_COUNT];
             final RulebaseRunner[] r = new RulebaseRunner[THREAD_COUNT];
             for ( int i = 0; i < t.length; i++ ) {