[jboss-svn-commits] JBL Code SVN: r30358 - labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl.

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

Author: salaboy21
Date: 2009-11-26 15:55:20 -0500 (Thu, 26 Nov 2009)
New Revision: 30358

Modified:
   labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/AssignObjectAsResult.java
   labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/ExecuteResultHandler.java
   labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/ExecutorStage.java
Log:
JBRULES-2347 Drools Pipeline integration with Camel
	-  changes to BaseEmitters to support camel calls

Modified: labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/AssignObjectAsResult.java
===================================================================
--- labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/AssignObjectAsResult.java	2009-11-26 20:53:22 UTC (rev 30357)
+++ labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/AssignObjectAsResult.java	2009-11-26 20:55:20 UTC (rev 30358)
@@ -12,9 +12,13 @@
         super();
     }
 
+    public void assignResult(PipelineContext context, Object object) {
+        context.setResult(object);
+    }
+
     public void receive(Object object,
                         PipelineContext context) {
-        context.setResult( object );
+        assignResult( context , object);
 
         emit( object,
               context );

Modified: labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/ExecuteResultHandler.java
===================================================================
--- labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/ExecuteResultHandler.java	2009-11-26 20:53:22 UTC (rev 30357)
+++ labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/ExecuteResultHandler.java	2009-11-26 20:55:20 UTC (rev 30358)
@@ -8,17 +8,18 @@
     implements
     Action {
 
+    public void handleResult(PipelineContext context, Object object) {
+        context.getResultHandler().handleResult(context.getResult());
+        try {
+            context.getResultHandler().handleResult(context.getResult());
+        } catch (Exception e) {
+            handleException(this, object, e);
+        }
+    }
+
     public void receive(Object object,
                         PipelineContext context) {
-        context.getResultHandler().handleResult( context.getResult() );
-
-        try {
-            context.getResultHandler().handleResult( context.getResult() );
-        } catch ( Exception e ) {
-            handleException( this,
-                             object,
-                             e );
-        }
+        handleResult(context, object);
         emit( object,
               context );
     }

Modified: labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/ExecutorStage.java
===================================================================
--- labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/ExecutorStage.java	2009-11-26 20:53:22 UTC (rev 30357)
+++ labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/ExecutorStage.java	2009-11-26 20:55:20 UTC (rev 30358)
@@ -12,17 +12,21 @@
 public class ExecutorStage extends BaseEmitter
     implements
     KnowledgeRuntimeCommand {
-
+    private ExecutionResults result = null;
     public void receive(Object object,
                         PipelineContext context) {
         BasePipelineContext kContext = (BasePipelineContext) context;
+        this.result = execute(object, kContext);
+        emit( result,
+              kContext );
+    }
+    public ExecutionResults execute(Object object, PipelineContext kContext){
+        
         if ( object instanceof Collection ) {
             object = CommandFactory.newBatchExecution( (List<Command>) object );
         }
-        ExecutionResults result = kContext.getCommandExecutor().execute( (Command) object );
-
-        emit( result,
-              kContext );
+         
+        return kContext.getCommandExecutor().execute( (Command) object );
     }
 
 }