[jboss-svn-commits] JBL Code SVN: r34157 - in labs/jbossrules/branches/salaboy_drools_grid_api_separation: drools-grid/drools-grid-distributed-api/src/main/java/org/drools/grid/distributed and 2 other directories.

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

Author: salaboy21
Date: 2010-07-25 16:17:50 -0400 (Sun, 25 Jul 2010)
New Revision: 34157

Modified:
   labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-api/src/main/java/org/drools/builder/DirectoryLookupFactoryService.java
   labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-grid/drools-grid-distributed-api/src/main/java/org/drools/grid/distributed/DirectoryLookupProviderGridClient.java
   labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-grid/drools-grid-local/src/main/java/org/drools/grid/local/DirectoryLookupProviderLocalClient.java
   labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-grid/drools-grid-remote-api/src/main/java/org/drools/grid/remote/DirectoryLookupProviderRemoteClient.java
Log:
adding Unregister session to the DirectoryLookupService

Modified: labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-api/src/main/java/org/drools/builder/DirectoryLookupFactoryService.java
===================================================================
--- labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-api/src/main/java/org/drools/builder/DirectoryLookupFactoryService.java	2010-07-25 16:52:16 UTC (rev 34156)
+++ labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-api/src/main/java/org/drools/builder/DirectoryLookupFactoryService.java	2010-07-25 20:17:50 UTC (rev 34157)
@@ -26,6 +26,7 @@
  */
 public interface DirectoryLookupFactoryService {
     public void register(String key, CommandExecutor value);
+    public void unregister(String key);
     public CommandExecutor lookup(String key);
     public Map<String, String> getDirectoryMap();
 }

Modified: labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-grid/drools-grid-distributed-api/src/main/java/org/drools/grid/distributed/DirectoryLookupProviderGridClient.java
===================================================================
--- labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-grid/drools-grid-distributed-api/src/main/java/org/drools/grid/distributed/DirectoryLookupProviderGridClient.java	2010-07-25 16:52:16 UTC (rev 34156)
+++ labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-grid/drools-grid-distributed-api/src/main/java/org/drools/grid/distributed/DirectoryLookupProviderGridClient.java	2010-07-25 20:17:50 UTC (rev 34157)
@@ -166,4 +166,8 @@
     public Map<String, String> getDirectoryMap() {
         throw new UnsupportedOperationException("Not supported yet.");
     }
+
+    public void unregister(String key) {
+        throw new UnsupportedOperationException("Not supported yet.");
+    }
 }

Modified: labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-grid/drools-grid-local/src/main/java/org/drools/grid/local/DirectoryLookupProviderLocalClient.java
===================================================================
--- labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-grid/drools-grid-local/src/main/java/org/drools/grid/local/DirectoryLookupProviderLocalClient.java	2010-07-25 16:52:16 UTC (rev 34156)
+++ labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-grid/drools-grid-local/src/main/java/org/drools/grid/local/DirectoryLookupProviderLocalClient.java	2010-07-25 20:17:50 UTC (rev 34157)
@@ -68,4 +68,16 @@
         return directory;
 
     }
+
+    public void unregister(String key) {
+        try {
+                DirectoryNodeService directoryNode = connection.getDirectoryNode().get(DirectoryNodeService.class);
+                directoryNode.unregister(key);
+            } catch (ConnectorException ex) {
+                Logger.getLogger(DirectoryLookupProviderLocalClient.class.getName()).log(Level.SEVERE, null, ex);
+            } catch (RemoteException ex) {
+                Logger.getLogger(DirectoryLookupProviderLocalClient.class.getName()).log(Level.SEVERE, null, ex);
+            }
+        services.remove(key);
+    }
 }

Modified: labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-grid/drools-grid-remote-api/src/main/java/org/drools/grid/remote/DirectoryLookupProviderRemoteClient.java
===================================================================
--- labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-grid/drools-grid-remote-api/src/main/java/org/drools/grid/remote/DirectoryLookupProviderRemoteClient.java	2010-07-25 16:52:16 UTC (rev 34156)
+++ labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-grid/drools-grid-remote-api/src/main/java/org/drools/grid/remote/DirectoryLookupProviderRemoteClient.java	2010-07-25 20:17:50 UTC (rev 34157)
@@ -66,7 +66,7 @@
 
             DirectoryNodeService directoryNode = connection.getDirectoryNode().get(DirectoryNodeService.class);
             try {
-                System.out.println("!!!!!!!!>>>>>>>>>>Registering in DirectoryNode the session = "+identifier);
+                
                 directoryNode.register(identifier, client.getId());
             } catch (RemoteException ex) {
                 Logger.getLogger(DirectoryLookupProviderRemoteClient.class.getName()).log(Level.SEVERE, null, ex);
@@ -175,4 +175,8 @@
     public String lookupId(String key) {
         throw new UnsupportedOperationException("Not supported yet.");
     }
+
+    public void unregister(String key) {
+        throw new UnsupportedOperationException("Not supported yet.");
+    }
 }