org.n52.wps.unicore.client
Class UnicoreTask

java.lang.Object
  org.n52.wps.unicore.client.UnicoreTask

All Implemented Interfaces:

java.util.concurrent.Callable<java.lang.Object>

public class UnicoreTask
extends java.lang.Object
implements java.util.concurrent.Callable<java.lang.Object>

Field Summary

protected UnicoreAlgorithmInput	inputData
static java.lang.String	JOB_EXECUTION_SCRIPT
protected de.fzj.unicore.uas.security.IUASSecurityProperties	securityProperties
static java.lang.String	TARGET_SYSTEM_INPUT_FILE_NAME
static java.lang.String	TARGET_SYSTEM_OUTPUT_FILE_NAME
protected de.fzj.unicore.uas.client.TSSClient	targetSystem
protected static int	WAIT_UNTIL_DONE_TIMEOUT
protected static int	WAIT_UNTIL_READY_TIMEOUT

Constructor Summary

UnicoreTask(de.fzj.unicore.uas.security.IUASSecurityProperties pSecurityProperties, de.fzj.unicore.uas.client.TSSClient pTargetSystem, UnicoreAlgorithmInput pInputData)

Method Summary

java.lang.Object	call()
protected UnicoreAlgorithmOutput	fetchOutputData(de.fzj.unicore.uas.client.StorageClient uspace)
protected org.ggf.schemas.jsdl.x2005.x11.jsdl.JobDefinitionDocument	getJobDefinition()
protected byte[]	stageOut(de.fzj.unicore.uas.client.StorageClient uspace, java.lang.String pFileName)
protected void	submitInputData(de.fzj.unicore.uas.client.StorageClient pSms, UnicoreAlgorithmInput pAlgorithmInput)
protected de.fzj.unicore.uas.client.JobClient	submitJob(de.fzj.unicore.uas.client.TSSClient tss)
protected void	submitWpsConfiguration(de.fzj.unicore.uas.client.StorageClient pSms)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

TARGET_SYSTEM_INPUT_FILE_NAME

public static final java.lang.String TARGET_SYSTEM_INPUT_FILE_NAME

See Also:

Constant Field Values

TARGET_SYSTEM_OUTPUT_FILE_NAME

public static final java.lang.String TARGET_SYSTEM_OUTPUT_FILE_NAME

See Also:

Constant Field Values

JOB_EXECUTION_SCRIPT

public static java.lang.String JOB_EXECUTION_SCRIPT

WAIT_UNTIL_READY_TIMEOUT

protected static int WAIT_UNTIL_READY_TIMEOUT

WAIT_UNTIL_DONE_TIMEOUT

protected static int WAIT_UNTIL_DONE_TIMEOUT

securityProperties

protected de.fzj.unicore.uas.security.IUASSecurityProperties securityProperties

targetSystem

protected de.fzj.unicore.uas.client.TSSClient targetSystem

inputData

protected UnicoreAlgorithmInput inputData

Constructor Detail

UnicoreTask

public UnicoreTask(de.fzj.unicore.uas.security.IUASSecurityProperties pSecurityProperties,
                   de.fzj.unicore.uas.client.TSSClient pTargetSystem,
                   UnicoreAlgorithmInput pInputData)

Method Detail

call

public java.lang.Object call()
                      throws java.lang.Exception

Specified by:

call in interface java.util.concurrent.Callable<java.lang.Object>

Throws:

java.lang.Exception

submitJob

protected de.fzj.unicore.uas.client.JobClient submitJob(de.fzj.unicore.uas.client.TSSClient tss)
                                                 throws java.lang.Exception

Throws:

java.lang.Exception

getJobDefinition

protected org.ggf.schemas.jsdl.x2005.x11.jsdl.JobDefinitionDocument getJobDefinition()

fetchOutputData

protected UnicoreAlgorithmOutput fetchOutputData(de.fzj.unicore.uas.client.StorageClient uspace)
                                          throws ExceptionReport

Throws:

ExceptionReport

stageOut

protected byte[] stageOut(de.fzj.unicore.uas.client.StorageClient uspace,
                          java.lang.String pFileName)
                   throws ExceptionReport

Throws:

ExceptionReport

submitInputData

protected void submitInputData(de.fzj.unicore.uas.client.StorageClient pSms,
                               UnicoreAlgorithmInput pAlgorithmInput)
                        throws java.lang.Exception

Throws:

java.lang.Exception

submitWpsConfiguration

protected void submitWpsConfiguration(de.fzj.unicore.uas.client.StorageClient pSms)
                               throws java.lang.Exception

Throws:

java.lang.Exception