[Mulgara-svn] r270 - branches/blank_nodes/src/jar/resolver-distributed/java/org/mulgara/resolver/distributed

[pag at mulgara.org]

Author: pag
Date: 2007-05-14 13:06:35 -0500 (Mon, 14 May 2007)
New Revision: 270

Modified:
   branches/blank_nodes/src/jar/resolver-distributed/java/org/mulgara/resolver/distributed/NetworkDelegator.java
Log:
more thorough exception handling for insert and delete

Modified: branches/blank_nodes/src/jar/resolver-distributed/java/org/mulgara/resolver/distributed/NetworkDelegator.java
===================================================================
--- branches/blank_nodes/src/jar/resolver-distributed/java/org/mulgara/resolver/distributed/NetworkDelegator.java	2007-05-11 16:02:32 UTC (rev 269)
+++ branches/blank_nodes/src/jar/resolver-distributed/java/org/mulgara/resolver/distributed/NetworkDelegator.java	2007-05-14 18:06:35 UTC (rev 270)
@@ -21,6 +21,7 @@
 import org.mulgara.query.ModelResource;
 import org.mulgara.query.Query;
 import org.mulgara.query.QueryException;
+import org.mulgara.query.TuplesException;
 import org.mulgara.query.UnconstrainedAnswer;
 import org.mulgara.query.Variable;
 import org.mulgara.query.rdf.URIReferenceImpl;
@@ -113,8 +114,14 @@
     URI serverUri = getServerUri(modelRef);
     logger.debug("Adding data to model: " + modelRef + " on server: " + serverUri);
     // convert the data to something shippable
-    Set statementSet = StatementSetFactory.newStatementSet(statements);
-    getServerSession(serverUri).insert(modelRef.getURI(), statementSet);
+    try {
+      Set statementSet = StatementSetFactory.newStatementSet(statements, session);
+      getServerSession(serverUri).insert(modelRef.getURI(), statementSet);
+    } catch (GlobalizeException ge) {
+      throw new ResolverException("Insertion data can't be sent over a network", ge);
+    } catch (TuplesException te) {
+      throw new ResolverException("Insertion data inaccessible", te);
+    }
   }
 
 
@@ -132,8 +139,14 @@
     URI serverUri = getServerUri(modelRef);
     logger.debug("Removing data from model: " + modelRef + " on server: " + serverUri);
     // convert the data to something shippable
-    Set statementSet = StatementSetFactory.newStatementSet(statements);
-    getServerSession(serverUri).delete(modelRef.getURI(), statementSet);
+    try {
+      Set statementSet = StatementSetFactory.newStatementSet(statements, session);
+      getServerSession(serverUri).delete(modelRef.getURI(), statementSet);
+    } catch (GlobalizeException ge) {
+      throw new ResolverException("Deletion data can't be sent over a network", ge);
+    } catch (TuplesException te) {
+      throw new ResolverException("Deletion data inaccessible", te);
+    }
   }