X-Git-Url: https://git.argeo.org/?a=blobdiff_plain;f=org.argeo.cms%2Fsrc%2Forg%2Fargeo%2Fcms%2Finternal%2Fkernel%2FNodeRepositoryFactory.java;h=47e8b5cd5e538d01497dd4fa682366daee997c2d;hb=5b3108fe285bca50565b58b63fa4feddc96c0765;hp=2e3e78f0da5b49380d55f453978f3f6ae78bbd48;hpb=0243aa5633af84d8608ba912483dbaaaefac42f1;p=lgpl%2Fargeo-commons.git

diff --git a/org.argeo.cms/src/org/argeo/cms/internal/kernel/NodeRepositoryFactory.java b/org.argeo.cms/src/org/argeo/cms/internal/kernel/NodeRepositoryFactory.java
index 2e3e78f0d..47e8b5cd5 100644
--- a/org.argeo.cms/src/org/argeo/cms/internal/kernel/NodeRepositoryFactory.java
+++ b/org.argeo.cms/src/org/argeo/cms/internal/kernel/NodeRepositoryFactory.java
@@ -28,13 +28,13 @@ import javax.jcr.RepositoryFactory;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 import org.apache.jackrabbit.jcr2dav.Jcr2davRepositoryFactory;
+import org.argeo.api.NodeConstants;
+import org.argeo.cms.internal.jcr.RepoConf;
 import org.argeo.jcr.ArgeoJcrException;
-import org.argeo.node.NodeConstants;
 import org.osgi.framework.BundleContext;
 import org.osgi.framework.FrameworkUtil;
 import org.osgi.framework.InvalidSyntaxException;
 import org.osgi.framework.ServiceReference;
-import org.springframework.core.io.Resource;
 
 /**
  * OSGi-aware Jackrabbit repository factory which can retrieve/publish
@@ -84,15 +84,16 @@ class NodeRepositoryFactory implements RepositoryFactory {
 		// check if remote
 		Repository repository;
 		String uri = null;
-		if (parameters.containsKey(NodeConstants.LABELED_URI))
+		if (parameters.containsKey(RepoConf.labeledUri.name()))
 			uri = parameters.get(NodeConstants.LABELED_URI).toString();
 		else if (parameters.containsKey(KernelConstants.JACKRABBIT_REPOSITORY_URI))
 			uri = parameters.get(KernelConstants.JACKRABBIT_REPOSITORY_URI).toString();
 
 		if (uri != null) {
-			if (uri.startsWith("http"))// http, https
-				repository = createRemoteRepository(uri);
-			else if (uri.startsWith("file"))// http, https
+			if (uri.startsWith("http")) {// http, https
+				Object defaultWorkspace = parameters.get(RepoConf.defaultWorkspace.name());
+				repository = createRemoteRepository(uri, defaultWorkspace != null ? defaultWorkspace.toString() : null);
+			} else if (uri.startsWith("file"))// http, https
 				repository = createFileRepository(uri, parameters);
 			else if (uri.startsWith("vm")) {
 				// log.warn("URI " + uri + " should have been managed by generic
@@ -120,9 +121,11 @@ class NodeRepositoryFactory implements RepositoryFactory {
 		return repository;
 	}
 
-	protected Repository createRemoteRepository(String uri) throws RepositoryException {
+	protected Repository createRemoteRepository(String uri, String defaultWorkspace) throws RepositoryException {
 		Map<String, String> params = new HashMap<String, String>();
 		params.put(KernelConstants.JACKRABBIT_REPOSITORY_URI, uri);
+		if (defaultWorkspace != null)
+			params.put(KernelConstants.JACKRABBIT_REMOTE_DEFAULT_WORKSPACE, defaultWorkspace);
 		Repository repository = new Jcr2davRepositoryFactory().getRepository(params);
 		if (repository == null)
 			throw new ArgeoJcrException("Remote Davex repository " + uri + " not found");
@@ -190,16 +193,10 @@ class NodeRepositoryFactory implements RepositoryFactory {
 	}
 
 	/**
-	 * Called after the repository has been initialised. Does nothing by
-	 * default.
+	 * Called after the repository has been initialised. Does nothing by default.
 	 */
 	@SuppressWarnings("rawtypes")
 	protected void postInitialization(Repository repository, Map parameters) {
 
 	}
-
-	public void setFileRepositoryConfiguration(Resource fileRepositoryConfiguration) {
-//		this.fileRepositoryConfiguration = fileRepositoryConfiguration;
-	}
-
 }