[jboss-svn-commits] JBL Code SVN: r12828 - labs/jbossesb/trunk/product/services/jbrules/src/main/java/org/jboss/internal/soa/esb/services/routing/cbr.

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

Author: kurt.stam at jboss.com
Date: 2007-06-25 11:05:56 -0400 (Mon, 25 Jun 2007)
New Revision: 12828

Modified:
   labs/jbossesb/trunk/product/services/jbrules/src/main/java/org/jboss/internal/soa/esb/services/routing/cbr/JBossRulesRouter.java
Log:
JBESB-642 adding dispose()

Modified: labs/jbossesb/trunk/product/services/jbrules/src/main/java/org/jboss/internal/soa/esb/services/routing/cbr/JBossRulesRouter.java
===================================================================
--- labs/jbossesb/trunk/product/services/jbrules/src/main/java/org/jboss/internal/soa/esb/services/routing/cbr/JBossRulesRouter.java	2007-06-25 15:03:50 UTC (rev 12827)
+++ labs/jbossesb/trunk/product/services/jbrules/src/main/java/org/jboss/internal/soa/esb/services/routing/cbr/JBossRulesRouter.java	2007-06-25 15:05:56 UTC (rev 12828)
@@ -34,7 +34,7 @@
 import org.apache.log4j.Level;
 import org.drools.RuleBase;
 import org.drools.RuleBaseFactory;
-import org.drools.WorkingMemory;
+import org.drools.StatefulSession;
 import org.drools.compiler.DroolsParserException;
 import org.drools.compiler.PackageBuilder;
 import org.drools.compiler.PackageBuilderConfiguration;
@@ -131,7 +131,7 @@
     			}
     			if (ruleSet != null) ruleSets.put(ruleSet, newRuleSet);
     		}
-    		WorkingMemory workingMemory = ruleBase.newStatefulSession();
+    		StatefulSession workingMemory = ruleBase.newStatefulSession();
     		logger.log(Level.DEBUG,
     				"Obtained message=" + message + " with ruleSet=" + ruleSet);
     		workingMemory.setGlobal("destinations", destinations);
@@ -145,6 +145,7 @@
     		workingMemory.fireAllRules();
     		logger.log(Level.DEBUG,
     				"Outgoing Destinations: " + destinations);
+            workingMemory.dispose();
             return destinations;
         } catch (IOException ioe) {
             throw new MessageRouterException("Could not read the rules. " +  ioe.getMessage(), ioe);