Skip to content
Snippets Groups Projects
Commit 0158056f authored by brinn's avatar brinn
Browse files

[LMS-1254] change: replace RPCServiceFactory.createServiceProxy() with...

[LMS-1254] change: replace RPCServiceFactory.createServiceProxy() with RPCServiceFactory.createCIFEXComponent() in DSS

SVN: 13263
parent 6342bc31
No related branches found
No related tags found
No related merge requests found
...@@ -25,7 +25,7 @@ import org.apache.commons.lang.StringUtils; ...@@ -25,7 +25,7 @@ import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.InitializingBean; import org.springframework.beans.factory.InitializingBean;
import ch.systemsx.cisd.base.exceptions.IOExceptionUnchecked; import ch.systemsx.cisd.base.exceptions.IOExceptionUnchecked;
import ch.systemsx.cisd.cifex.rpc.ICIFEXRPCService; import ch.systemsx.cisd.cifex.rpc.client.ICIFEXComponent;
import ch.systemsx.cisd.common.exceptions.InvalidAuthenticationException; import ch.systemsx.cisd.common.exceptions.InvalidAuthenticationException;
import ch.systemsx.cisd.common.exceptions.InvalidSessionException; import ch.systemsx.cisd.common.exceptions.InvalidSessionException;
import ch.systemsx.cisd.common.spring.AbstractServiceWithLogger; import ch.systemsx.cisd.common.spring.AbstractServiceWithLogger;
...@@ -176,10 +176,10 @@ public class DataStoreService extends AbstractServiceWithLogger<IDataStoreServic ...@@ -176,10 +176,10 @@ public class DataStoreService extends AbstractServiceWithLogger<IDataStoreServic
ICIFEXRPCServiceFactory serviceFactory = ICIFEXRPCServiceFactory serviceFactory =
createCIFEXRPCServiceFactory(context.getCifexURL()); createCIFEXRPCServiceFactory(context.getCifexURL());
ICIFEXRPCService service = serviceFactory.createService(); ICIFEXComponent cifex = serviceFactory.createCIFEXComponent();
String userID = context.getUserID(); String userID = context.getUserID();
String password = context.getPassword(); String password = context.getPassword();
if (service.login(userID, password) == null) if (cifex.login(userID, password) == null)
{ {
throw new InvalidSessionException("User couldn't be authenticated at CIFEX."); throw new InvalidSessionException("User couldn't be authenticated at CIFEX.");
} }
......
...@@ -18,14 +18,14 @@ package ch.systemsx.cisd.openbis.dss.generic.server; ...@@ -18,14 +18,14 @@ package ch.systemsx.cisd.openbis.dss.generic.server;
import java.io.Serializable; import java.io.Serializable;
import ch.systemsx.cisd.cifex.rpc.ICIFEXRPCService; import ch.systemsx.cisd.cifex.rpc.client.ICIFEXComponent;
/** /**
* * Factory for {@link ICIFEXComponent}.
* *
* @author Franz-Josef Elmer * @author Franz-Josef Elmer
*/ */
public interface ICIFEXRPCServiceFactory extends Serializable public interface ICIFEXRPCServiceFactory extends Serializable
{ {
public ICIFEXRPCService createService(); public ICIFEXComponent createCIFEXComponent();
} }
...@@ -37,8 +37,8 @@ import org.apache.commons.lang.StringUtils; ...@@ -37,8 +37,8 @@ import org.apache.commons.lang.StringUtils;
import org.apache.log4j.Logger; import org.apache.log4j.Logger;
import ch.rinn.restrictions.Private; import ch.rinn.restrictions.Private;
import ch.systemsx.cisd.cifex.rpc.ICIFEXRPCService; import ch.systemsx.cisd.cifex.rpc.client.ICIFEXComponent;
import ch.systemsx.cisd.cifex.rpc.client.Uploader; import ch.systemsx.cisd.cifex.rpc.client.ICIFEXUploader;
import ch.systemsx.cisd.cifex.rpc.client.gui.IProgressListener; import ch.systemsx.cisd.cifex.rpc.client.gui.IProgressListener;
import ch.systemsx.cisd.cifex.shared.basic.Constants; import ch.systemsx.cisd.cifex.shared.basic.Constants;
import ch.systemsx.cisd.common.logging.LogCategory; import ch.systemsx.cisd.common.logging.LogCategory;
...@@ -297,9 +297,9 @@ class UploadingCommand implements IDataSetCommand ...@@ -297,9 +297,9 @@ class UploadingCommand implements IDataSetCommand
operationLog.info("Zip file " + zipFile + " with " + dataSets.size() operationLog.info("Zip file " + zipFile + " with " + dataSets.size()
+ " data sets has been successfully created."); + " data sets has been successfully created.");
} }
ICIFEXRPCService cifexService = cifexServiceFactory.createService(); ICIFEXComponent cifex = cifexServiceFactory.createCIFEXComponent();
String sessionToken = cifexService.login(userID, password); String sessionToken = cifex.login(userID, password);
Uploader uploader = new Uploader(cifexService, sessionToken); ICIFEXUploader uploader = cifex.createUploader(sessionToken);
uploader.addProgressListener(new ProgressListener(zipFile)); uploader.addProgressListener(new ProgressListener(zipFile));
uploader.upload(Arrays.asList(zipFile), Constants.USER_ID_PREFIX + userID, comment); uploader.upload(Arrays.asList(zipFile), Constants.USER_ID_PREFIX + userID, comment);
} else } else
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment