[jboss-svn-commits] JBL Code SVN: r35953 - in labs/jbossrules/trunk: drools-grid/drools-grid-impl/src/main/java/org/drools/grid/remote and 1 other directory.

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

Author: salaboy21
Date: 2010-11-11 16:22:38 -0500 (Thu, 11 Nov 2010)
New Revision: 35953

Modified:
   labs/jbossrules/trunk/drools-core/src/main/java/org/drools/command/runtime/rule/GetFactHandleCommand.java
   labs/jbossrules/trunk/drools-grid/drools-grid-impl/src/main/java/org/drools/grid/remote/StatefulKnowledgeSessionRemoteClient.java
Log:
JBRULES-2772: Drools Grid Impl2 remoting features (socket)
	- Adding disconnected mode to GetFactHandleCommand

Modified: labs/jbossrules/trunk/drools-core/src/main/java/org/drools/command/runtime/rule/GetFactHandleCommand.java
===================================================================
--- labs/jbossrules/trunk/drools-core/src/main/java/org/drools/command/runtime/rule/GetFactHandleCommand.java	2010-11-11 21:14:42 UTC (rev 35952)
+++ labs/jbossrules/trunk/drools-core/src/main/java/org/drools/command/runtime/rule/GetFactHandleCommand.java	2010-11-11 21:22:38 UTC (rev 35953)
@@ -19,7 +19,7 @@
 import org.drools.command.Context;
 import org.drools.command.impl.GenericCommand;
 import org.drools.command.impl.KnowledgeCommandContext;
-import org.drools.reteoo.ReteooWorkingMemory;
+import org.drools.common.DefaultFactHandle;
 import org.drools.runtime.StatefulKnowledgeSession;
 import org.drools.runtime.rule.FactHandle;
 
@@ -28,14 +28,25 @@
     GenericCommand<FactHandle> {
 
     private Object object;
+    private boolean disconnected;
 
     public GetFactHandleCommand(Object object) {
         this.object = object;
+        this.disconnected = false;
     }
+    
+    public GetFactHandleCommand(Object object, boolean disconnected) {
+        this.object = object;
+        this.disconnected = disconnected;
+    }
 
     public FactHandle execute(Context context) {
         StatefulKnowledgeSession ksession = ((KnowledgeCommandContext) context).getStatefulKnowledgesession();
-        return ksession.getFactHandle( object );
+        FactHandle factHandle = ksession.getFactHandle( object );
+        if ( disconnected ){
+            ((DefaultFactHandle)factHandle).disconnect();
+        }
+        return factHandle;
     }
 
     public String toString() {

Modified: labs/jbossrules/trunk/drools-grid/drools-grid-impl/src/main/java/org/drools/grid/remote/StatefulKnowledgeSessionRemoteClient.java
===================================================================
--- labs/jbossrules/trunk/drools-grid/drools-grid-impl/src/main/java/org/drools/grid/remote/StatefulKnowledgeSessionRemoteClient.java	2010-11-11 21:14:42 UTC (rev 35952)
+++ labs/jbossrules/trunk/drools-grid/drools-grid-impl/src/main/java/org/drools/grid/remote/StatefulKnowledgeSessionRemoteClient.java	2010-11-11 21:22:38 UTC (rev 35953)
@@ -396,7 +396,7 @@
     public FactHandle getFactHandle(Object object) {
         String kresultsId = "kresults_" + this.gsd.getId();
         CommandImpl cmd = new CommandImpl("execute",
-                Arrays.asList(new Object[]{ new KnowledgeContextResolveFromContextCommand( new GetFactHandleCommand( object ),
+                Arrays.asList(new Object[]{ new KnowledgeContextResolveFromContextCommand( new GetFactHandleCommand( object, true ),
                                                                                   null,
                                                                                   null,
                                                                                   this.instanceId,