[jboss-svn-commits] JBL Code SVN: r7248 - in labs/jbossrules/contrib/benchmarks/src/java/benchmarks: . manners

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

Author: mark.proctor at jboss.com
Date: 2006-10-31 08:53:43 -0500 (Tue, 31 Oct 2006)
New Revision: 7248

Modified:
   labs/jbossrules/contrib/benchmarks/src/java/benchmarks/Benchmark.java
   labs/jbossrules/contrib/benchmarks/src/java/benchmarks/manners/JessJavaBeanManners.java
   labs/jbossrules/contrib/benchmarks/src/java/benchmarks/manners/JessManners.java
Log:
-Added a JessListener, but its not working yet.

Modified: labs/jbossrules/contrib/benchmarks/src/java/benchmarks/Benchmark.java
===================================================================
--- labs/jbossrules/contrib/benchmarks/src/java/benchmarks/Benchmark.java	2006-10-31 12:04:20 UTC (rev 7247)
+++ labs/jbossrules/contrib/benchmarks/src/java/benchmarks/Benchmark.java	2006-10-31 13:53:43 UTC (rev 7248)
@@ -1,7 +1,5 @@
 package benchmarks;
 
-import java.util.List;
-
 import benchmarks.BaseBenchmark.Stats;
 
 public interface Benchmark {

Modified: labs/jbossrules/contrib/benchmarks/src/java/benchmarks/manners/JessJavaBeanManners.java
===================================================================
--- labs/jbossrules/contrib/benchmarks/src/java/benchmarks/manners/JessJavaBeanManners.java	2006-10-31 12:04:20 UTC (rev 7247)
+++ labs/jbossrules/contrib/benchmarks/src/java/benchmarks/manners/JessJavaBeanManners.java	2006-10-31 13:53:43 UTC (rev 7248)
@@ -10,7 +10,12 @@
 import benchmarks.Benchmark;
 import benchmarks.BaseBenchmark.Stats;
 
+import jess.Activation;
+import jess.Defrule;
 import jess.Funcall;
+import jess.JessEvent;
+import jess.JessException;
+import jess.JessListener;
 import jess.RU;
 import jess.Rete;
 import jess.Value;
@@ -19,11 +24,36 @@
     implements
     Benchmark {    
     Rete rete = new Rete();
+    private final Stats stats  = new Stats();
 
     public void init(String fileName, boolean buildStats) throws Exception {
         rete.executeCommand("(clear)");
         rete.executeCommand("(batch \"benchmarks/manners/"+fileName+"\")");
         rete.executeCommand("(reset)");
+        
+        JessListener listener  = new JessListener()  {
+            public void eventHappened(JessEvent event) throws JessException {
+                System.out.println( "help" );
+                switch ( event.getTag() ) {
+                    case JessEvent.DEFRULE_FIRED:
+                        Defrule rule =  ( Defrule ) event.getSource();
+                        stats.fired( rule.getName() );
+                        break;
+                    case JessEvent.ACTIVATION:
+                        Activation activation = (Activation) event.getSource();
+                        if ( activation.isInactive() ) {
+                            stats.cancelled( activation.getRule().getName() );
+                        } else  {
+                            stats.created( activation.getRule().getName() );
+                        }
+                        break;
+                }                
+            }            
+        };
+        
+        if( buildStats ) {
+            rete.addJessListener( listener );
+        }
     }
 
     public void assertObjects(String fileName) throws Exception {

Modified: labs/jbossrules/contrib/benchmarks/src/java/benchmarks/manners/JessManners.java
===================================================================
--- labs/jbossrules/contrib/benchmarks/src/java/benchmarks/manners/JessManners.java	2006-10-31 12:04:20 UTC (rev 7247)
+++ labs/jbossrules/contrib/benchmarks/src/java/benchmarks/manners/JessManners.java	2006-10-31 13:53:43 UTC (rev 7248)
@@ -3,17 +3,46 @@
 import benchmarks.Benchmark;
 import benchmarks.BaseBenchmark.Stats;
 
+import jess.Activation;
+import jess.Defrule;
+import jess.JessEvent;
+import jess.JessException;
+import jess.JessListener;
 import jess.Rete;
 
 public class JessManners
     implements
     Benchmark {    
     Rete rete = new Rete();
+    private final Stats stats  = new Stats();
 
     public void init(String fileName, boolean buildStats) throws Exception {
         rete.executeCommand("(clear)");
         rete.executeCommand("(batch \"benchmarks/manners/"+fileName+"\")");
         rete.executeCommand("(reset)");
+        
+        JessListener listener  = new JessListener()  {
+            public void eventHappened(JessEvent event) throws JessException {
+                switch ( event.getTag() ) {
+                    case JessEvent.DEFRULE_FIRED:
+                        Defrule rule =  ( Defrule ) event.getSource();
+                        stats.fired( rule.getName() );
+                        break;
+                    case JessEvent.ACTIVATION:
+                        Activation activation = (Activation) event.getSource();
+                        if ( activation.isInactive() ) {
+                            stats.cancelled( activation.getRule().getName() );
+                        } else  {
+                            stats.created( activation.getRule().getName() );
+                        }
+                        break;
+                }                
+            }            
+        };
+        
+        if( buildStats ) {
+            rete.addJessListener( listener );
+        }
     }
     
     public Stats getStats() {