[jboss-svn-commits] JBL Code SVN: r12021 - labs/jbossrules/trunk/drools-core/src/main/java/org/drools/reteoo.

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

Author: mark.proctor at jboss.com
Date: 2007-05-21 11:04:06 -0400 (Mon, 21 May 2007)
New Revision: 12021

Modified:
   labs/jbossrules/trunk/drools-core/src/main/java/org/drools/reteoo/QueryTerminalNode.java
Log:
JBRULES-862 QueryTerminalNode does not implement TupleSinkNode
-This meant that if the terminal node was added to a composite source, it would raise a class cast exception.

Modified: labs/jbossrules/trunk/drools-core/src/main/java/org/drools/reteoo/QueryTerminalNode.java
===================================================================
--- labs/jbossrules/trunk/drools-core/src/main/java/org/drools/reteoo/QueryTerminalNode.java	2007-05-21 14:36:57 UTC (rev 12020)
+++ labs/jbossrules/trunk/drools-core/src/main/java/org/drools/reteoo/QueryTerminalNode.java	2007-05-21 15:04:06 UTC (rev 12021)
@@ -37,7 +37,7 @@
  */
 public final class QueryTerminalNode extends BaseNode
     implements
-    TupleSink,
+    TupleSinkNode,
     NodeMemory,
     TerminalNode {
     // ------------------------------------------------------------
@@ -52,6 +52,9 @@
     private final Rule         rule;
     private final GroupElement subrule;
     private final TupleSource  tupleSource;
+    
+    private TupleSinkNode      previousTupleSinkNode;
+    private TupleSinkNode      nextTupleSinkNode;    
 
     // ------------------------------------------------------------
     // Constructors
@@ -170,5 +173,41 @@
     public GroupElement getSubrule() {
         return this.subrule;
     }
+    
+    /**
+     * Returns the previous node
+     * @return
+     *      The previous TupleSinkNode
+     */
+    public TupleSinkNode getPreviousTupleSinkNode() {
+        return this.previousTupleSinkNode;
+    }
 
+    /**
+     * Sets the previous node 
+     * @param previous
+     *      The previous TupleSinkNode
+     */
+    public void setPreviousTupleSinkNode(final TupleSinkNode previous) {
+        this.previousTupleSinkNode = previous;
+    }    
+    
+    /**
+     * Returns the next node
+     * @return
+     *      The next TupleSinkNode
+     */
+    public TupleSinkNode getNextTupleSinkNode() {
+        return this.nextTupleSinkNode;
+    }
+
+    /**
+     * Sets the next node 
+     * @param next
+     *      The next TupleSinkNode
+     */
+    public void setNextTupleSinkNode(final TupleSinkNode next) {
+        this.nextTupleSinkNode = next;
+    }    
+
 }