[jboss-svn-commits] JBL Code SVN: r18982 - 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 11:58:51 -0400 (Fri, 14 Mar 2008)
New Revision: 18982

Modified:
   labs/jbossrules/branches/ming-serialization/drools-compiler/src/test/java/org/drools/integrationtests/StatelessStressTest.java
Log:
added serialization for all rulebase & stateless session

Modified: labs/jbossrules/branches/ming-serialization/drools-compiler/src/test/java/org/drools/integrationtests/StatelessStressTest.java
===================================================================
--- labs/jbossrules/branches/ming-serialization/drools-compiler/src/test/java/org/drools/integrationtests/StatelessStressTest.java	2008-03-14 15:51:17 UTC (rev 18981)
+++ labs/jbossrules/branches/ming-serialization/drools-compiler/src/test/java/org/drools/integrationtests/StatelessStressTest.java	2008-03-14 15:58:51 UTC (rev 18982)
@@ -1,17 +1,18 @@
 package org.drools.integrationtests;
 
-import java.io.InputStreamReader;
-import java.util.ArrayList;
-import java.util.List;
-
+import junit.framework.TestCase;
 import org.drools.Address;
 import org.drools.Person;
+import org.drools.rule.Package;
 import org.drools.RuleBase;
 import org.drools.RuleBaseFactory;
 import org.drools.StatelessSession;
 import org.drools.compiler.PackageBuilder;
 
-import junit.framework.TestCase;
+import java.io.InputStreamReader;
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.List;
 
 /**
  * This is for testing possible PermSpace issues (leaking) when spawning lots of sessions in concurrent threads.
@@ -23,6 +24,13 @@
     public void testDummy() {
         
     }
+
+    private static RuleBase getRuleBase(Package pkg) throws IOException, ClassNotFoundException {
+        RuleBase ruleBase    = RuleBaseFactory.newRuleBase();
+
+        ruleBase.addPackage( pkg );
+        return SerializationHelper.serializeObject(ruleBase);
+    }
     
     
     public void XXXtestLotsOfStateless() throws Exception {
@@ -33,11 +41,8 @@
         
         
 
-        final RuleBase rb  = RuleBaseFactory.newRuleBase();
-        rb.addPackage( builder.getPackage() );
-        
-      
-        
+        final RuleBase rb  = getRuleBase( builder.getPackage() );
+
         int numThreads = 100;
         Thread[] ts = new Thread[numThreads];
         
@@ -53,6 +58,11 @@
                         while (true) {
                             start = System.currentTimeMillis();
                             StatelessSession sess = rb.newStatelessSession();
+                            try {
+                                sess    = SerializationHelper.serializeObject(sess);
+                            } catch (Exception ex) {
+                                throw new RuntimeException(ex);
+                            }
                             Person p = new Person();
                             p.setName( "Michael" ); 
                             Address add1 = new Address();