[jboss-svn-commits] JBL Code SVN: r31539 - in labs/jbossrules/branches/salaboy_grid-rio2: drools-grid-rio/src/main/java/org/drools/vsm/grid and 2 other directories.

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

Author: salaboy21
Date: 2010-02-09 21:01:53 -0500 (Tue, 09 Feb 2010)
New Revision: 31539

Modified:
   labs/jbossrules/branches/salaboy_grid-rio2/drools-core/src/main/java/org/drools/command/runtime/GetKnowledgeBaseCommand.java
   labs/jbossrules/branches/salaboy_grid-rio2/drools-grid-rio/src/main/java/org/drools/vsm/grid/GenericMessageGridHandlerImpl.java
   labs/jbossrules/branches/salaboy_grid-rio2/drools-grid-rio/src/main/java/org/drools/vsm/rio/command/NewStatefulKnowledgeSessionGridCommand.java
   labs/jbossrules/branches/salaboy_grid-rio2/drools-grid-rio/src/main/java/org/drools/vsm/rio/service/RegistryServiceImpl.java
Log:
sharing kbases done! very nasty.. it's time to refactor!

Modified: labs/jbossrules/branches/salaboy_grid-rio2/drools-core/src/main/java/org/drools/command/runtime/GetKnowledgeBaseCommand.java
===================================================================
--- labs/jbossrules/branches/salaboy_grid-rio2/drools-core/src/main/java/org/drools/command/runtime/GetKnowledgeBaseCommand.java	2010-02-10 01:21:53 UTC (rev 31538)
+++ labs/jbossrules/branches/salaboy_grid-rio2/drools-core/src/main/java/org/drools/command/runtime/GetKnowledgeBaseCommand.java	2010-02-10 02:01:53 UTC (rev 31539)
@@ -14,7 +14,8 @@
 
     public KnowledgeBase execute(Context context) {
         KnowledgeBase kbase = ((KnowledgeCommandContext) context).getKnowledgeBase();
-        System.out.println("The kbase is ="+kbase);
+        
+        ((KnowledgeCommandContext)context).set("kbase",kbase);
         return kbase;
     }
 

Modified: labs/jbossrules/branches/salaboy_grid-rio2/drools-grid-rio/src/main/java/org/drools/vsm/grid/GenericMessageGridHandlerImpl.java
===================================================================
--- labs/jbossrules/branches/salaboy_grid-rio2/drools-grid-rio/src/main/java/org/drools/vsm/grid/GenericMessageGridHandlerImpl.java	2010-02-10 01:21:53 UTC (rev 31538)
+++ labs/jbossrules/branches/salaboy_grid-rio2/drools-grid-rio/src/main/java/org/drools/vsm/grid/GenericMessageGridHandlerImpl.java	2010-02-10 02:01:53 UTC (rev 31539)
@@ -117,13 +117,21 @@
             cmd.execute( localSessionContext );
         }
 
-        if ( !msg.isAsync() && localKresults.getIdentifiers().isEmpty() ) {
+        if(localSessionContext.get("kbase") != null){
+            session.write( new Message( msg.getSessionId(),
+                                        msg.getResponseId(),
+                                        msg.isAsync(),
+                                        localSessionContext.get("kbase") ), null );
+        
+        } else if ( !msg.isAsync() && localKresults.getIdentifiers().isEmpty() ) {
             // if it's not an async invocation and their are no results, just send a simple notification message
             session.write( new Message( msg.getSessionId(),
                                         msg.getResponseId(),
                                         msg.isAsync(),
                                         new FinishedCommand() ), null );
-        } else {
+
+
+        }  else{
             // return the payload
             session.write( new Message( msg.getSessionId(),
                                         msg.getResponseId(),

Modified: labs/jbossrules/branches/salaboy_grid-rio2/drools-grid-rio/src/main/java/org/drools/vsm/rio/command/NewStatefulKnowledgeSessionGridCommand.java
===================================================================
--- labs/jbossrules/branches/salaboy_grid-rio2/drools-grid-rio/src/main/java/org/drools/vsm/rio/command/NewStatefulKnowledgeSessionGridCommand.java	2010-02-10 01:21:53 UTC (rev 31538)
+++ labs/jbossrules/branches/salaboy_grid-rio2/drools-grid-rio/src/main/java/org/drools/vsm/rio/command/NewStatefulKnowledgeSessionGridCommand.java	2010-02-10 02:01:53 UTC (rev 31539)
@@ -11,6 +11,7 @@
 import org.drools.command.impl.KnowledgeCommandContext;
 import org.drools.runtime.KnowledgeSessionConfiguration;
 import org.drools.runtime.StatefulKnowledgeSession;
+import org.drools.runtime.impl.ExecutionResultImpl;
 import org.drools.vsm.grid.RegistryService;
 
 public class NewStatefulKnowledgeSessionGridCommand
@@ -51,6 +52,7 @@
         if ( this.ksessionConf == null ) {
             System.out.println("Kbase inside the newStatefull Session = "+kbase);
             ksession = kbase.newStatefulKnowledgeSession();
+            
         } else {
             ksession = kbase.newStatefulKnowledgeSession( this.ksessionConf, null );
         }

Modified: labs/jbossrules/branches/salaboy_grid-rio2/drools-grid-rio/src/main/java/org/drools/vsm/rio/service/RegistryServiceImpl.java
===================================================================
--- labs/jbossrules/branches/salaboy_grid-rio2/drools-grid-rio/src/main/java/org/drools/vsm/rio/service/RegistryServiceImpl.java	2010-02-10 01:21:53 UTC (rev 31538)
+++ labs/jbossrules/branches/salaboy_grid-rio2/drools-grid-rio/src/main/java/org/drools/vsm/rio/service/RegistryServiceImpl.java	2010-02-10 02:01:53 UTC (rev 31539)
@@ -81,6 +81,7 @@
             Message msg = sessionService.write(new Message(999,1000,false, new KnowledgeContextResolveFromContextCommand( new GetKnowledgeBaseCommand(), null, kbaseId, null, null)));
             System.out.println("MSG returned by sessionService = "+msg);
             if (msg.getPayload() instanceof KnowledgeBase) {
+                System.out.println("Kbase in the payload: "+(KnowledgeBase)msg.getPayload());
                 return (KnowledgeBase)msg.getPayload();
             }
             return null;