gCubeSystem
/
smart-executor-client
16
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Implementing client 

git-svn-id: https://svn.d4science.research-infrastructures.eu/gcube/trunk/vre-management/smart-executor-client@111733 82a268e6-3cf1-43bd-a215-b396298e98cf
This commit is contained in:
Luca Frosini 2015-02-05 15:28:41 +00:00
parent bd48f86cbe
commit a4ea63516d
3 changed files with 26 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
pom.xml
View File

@ -37,6 +37,16 @@
<artifactId>common-generic-clients</artifactId>
<version>[1.0.0-SNAPSHOT,2.0.0-SNAPSHOT)</version>
</dependency>
<dependency>
<groupId>org.gcube.core</groupId>
<artifactId>common-gcube-calls</artifactId>
<version>[1.0.0-SNAPSHOT,2.0.0-SNAPSHOT)</version>
</dependency>
<dependency>
<groupId>org.gcube.core</groupId>
<artifactId>common-jaxws-calls</artifactId>
<version>[1.0.0-SNAPSHOT,2.0.0-SNAPSHOT)</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>

8
src/main/java/org/gcube/vremanagement/executor/client/DefaultExecutor.java → src/main/java/org/gcube/vremanagement/executor/client/DefaultExecutorProxy.java
View File

@ -21,16 +21,16 @@ import org.slf4j.LoggerFactory;
/**
* @author Luca Frosini (ISTI - CNR) http://www.lucafrosini.com/
*/
public class DefaultExecutor implements ExecutorProxy {
public class DefaultExecutorProxy implements ExecutorProxy {
/**
* Logger
*/
private static Logger logger = LoggerFactory.getLogger(DefaultExecutor.class);
private static Logger logger = LoggerFactory.getLogger(DefaultExecutorProxy.class);
private ProxyDelegate<Executor> proxyDelegate;
public DefaultExecutor(ProxyDelegate<Executor> proxyDelegate) {
public DefaultExecutorProxy(ProxyDelegate<Executor> proxyDelegate) {
this.proxyDelegate = proxyDelegate;
}
@ -39,8 +39,8 @@ public class DefaultExecutor implements ExecutorProxy {
public String launch(final LaunchParameter launchParameter)
throws InputsNullException, PluginNotFoundException,
LaunchException, ExecutorException {
Call<Executor, String> call = new Call<Executor, String>() {
@Override
public String call(Executor endpoint) throws Exception {
logger.debug("Calling launch() function");

13
src/main/java/org/gcube/vremanagement/executor/client/ExecutorProxy.java
View File

@ -3,12 +3,23 @@
*/
package org.gcube.vremanagement.executor.client;
import javax.xml.namespace.QName;
import org.gcube.common.calls.jaxws.GcubeService;
import org.gcube.vremanagement.executor.api.Executor;
/**
* @author Luca Frosini (ISTI - CNR) http://www.lucafrosini.com/
*
*
*/
public interface ExecutorProxy extends Executor {
/* Must be the same of generated WEB-INF/gcube-app.xml */
public static final String SERVICE_CLASS = "VREManagement";
public static final String SERVICE_NAME = "smart-executor";
public static final String NAMESPACE = "http://gcube-system.org/namespaces/common/vremanagement/smart-executor";
public static final QName EXECUTOR_QNAME = new QName(Executor.TNS, Executor.SERVICE_NAME);
public static final GcubeService<Executor> executor = GcubeService.service().withName(EXECUTOR_QNAME).andInterface(Executor.class);
}