com.intel.gpe.clients.api.workflow
Class AtomicJob

java.lang.Object
  com.intel.gpe.clients.api.workflow.AtomicJob

All Implemented Interfaces:

Action

public abstract class AtomicJob
extends java.lang.Object
implements Action

The complex action for performing an atomic job invocation. The performed actions may be presented in a pseudo-code: job = targetSystem.submit(jobDescription) wait until job.status = ready or job.status = failed if job.status = ready then job.start wait until job.status = successful or job.status = failed fi

Version:

$Id: AtomicJob.java,v 1.17 2006/11/17 08:41:28 vashorin Exp $

Author:

Alexander Lukichev

Field Summary

protected java.util.Calendar	initialTerminationTime
protected Job	jobDefinition

Constructor Summary

AtomicJob(Job jobDefinition, java.util.Calendar initialTerminationTime, PartnerLink targetSystem, com.intel.gpe.util.xml.Namespaces namespaces)
Create the AtomicJob complex action.

Method Summary

void	emitCode(Scope scope, org.w3c.dom.Element target) Emit the piece of code corresponding to the current action.
protected abstract java.lang.String	getBPEL4WSNS()
Variable	getGetJobStateRequest()
Variable	getGetJobStateResponse()
protected abstract VariableValue	getGetJobStatusRequestValue()
protected abstract VariableValue	getGetJobStatusResponseValue()
Variable	getGetJobWorkingDirectoryResponse()
protected abstract VariableValue	getGetJobWorkingDirectoryResponseValue()
protected abstract javax.xml.namespace.QName	getGetResourcePropertyPortType()
Variable	getJobDefinition() Get the variable where the job definition of the submitted job is stored
PartnerLink	getJobManagement()
protected abstract java.lang.String	getJobManagementNS()
PartnerLink	getJobManagementPartnerLink() Get the partner link to the created job management resource
protected abstract PartnerLinkValue	getJobManagementPartnerLinkValue()
protected abstract javax.xml.namespace.QName	getJobManagementPortType()
Variable	getJobState()
protected abstract VariableValue	getJobStateValue()
Variable	getJobStatus() Get the variable where the job's status is stored
Variable	getJobStatusChangeNotification()
protected abstract VariableValue	getJobStatusChangeNotificationValue()
protected abstract java.lang.String	getJSDLNS()
com.intel.gpe.util.xml.Namespaces	getNamespaces()
protected abstract javax.xml.namespace.QName	getNotificationConsumerPortType()
protected abstract javax.xml.namespace.QName	getNotificationProducerPortType()
Variable	getStartJobRequest()
Variable	getStartJobResponse()
protected abstract VariableValue	getStartRequestValue()
protected abstract VariableValue	getStartResponseValue()
Variable	getSubmitJobRequest()
protected abstract VariableValue	getSubmitJobRequestValue()
Variable	getSubmitJobResponse()
protected abstract VariableValue	getSubmitJobResponseValue()
protected abstract VariableValue	getSubscribeToJobStatusChangeNotificationRequestValue()
protected abstract VariableValue	getSubscribeToJobStatusChangeNotificationResponseValue()
Variable	getSubscribeToJobStatusChangeNotificationsRequest()
Variable	getSubscribeToJobStatusChangeNotificationsResponse()
PartnerLink	getTargetSystem()
protected abstract java.lang.String	getTargetSystemNS()
protected abstract javax.xml.namespace.QName	getTargetSystemPortType()
protected abstract java.lang.String	getUnigridsNS()
Variable	getWorkingDirectory() Get the endpoint reference of the working directory storage resource
protected abstract java.lang.String	getWSNotificationsSchemaNS()
protected abstract java.lang.String	getWSNotificationsWSDLNS()
void	setTargetSystem(PartnerLink targetSystem)

Methods inherited from class java.lang.Object

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

Field Detail

jobDefinition

protected Job jobDefinition

initialTerminationTime

protected java.util.Calendar initialTerminationTime

Constructor Detail

AtomicJob

public AtomicJob(Job jobDefinition,
                 java.util.Calendar initialTerminationTime,
                 PartnerLink targetSystem,
                 com.intel.gpe.util.xml.Namespaces namespaces)
          throws java.lang.Exception

Create the AtomicJob complex action.

Parameters:

jobDefinition - The definition of the job

initialTerminationTime - The initial termination time for the created job resource

targetSystem - The target system where to submit the job to

namespaces - The currently defined namespaces

Throws:

java.lang.Exception

Method Detail

getGetJobWorkingDirectoryResponseValue

protected abstract VariableValue getGetJobWorkingDirectoryResponseValue()

getJobManagementPartnerLinkValue

protected abstract PartnerLinkValue getJobManagementPartnerLinkValue()

getStartResponseValue

protected abstract VariableValue getStartResponseValue()

getStartRequestValue

protected abstract VariableValue getStartRequestValue()

getGetJobStatusResponseValue

protected abstract VariableValue getGetJobStatusResponseValue()

getGetJobStatusRequestValue

protected abstract VariableValue getGetJobStatusRequestValue()

getJobStateValue

protected abstract VariableValue getJobStateValue()

getJobStatusChangeNotificationValue

protected abstract VariableValue getJobStatusChangeNotificationValue()

getSubscribeToJobStatusChangeNotificationResponseValue

protected abstract VariableValue getSubscribeToJobStatusChangeNotificationResponseValue()

getSubscribeToJobStatusChangeNotificationRequestValue

protected abstract VariableValue getSubscribeToJobStatusChangeNotificationRequestValue()

getSubmitJobResponseValue

protected abstract VariableValue getSubmitJobResponseValue()

getSubmitJobRequestValue

protected abstract VariableValue getSubmitJobRequestValue()

getWSNotificationsSchemaNS

protected abstract java.lang.String getWSNotificationsSchemaNS()

getJobManagementNS

protected abstract java.lang.String getJobManagementNS()

getWSNotificationsWSDLNS

protected abstract java.lang.String getWSNotificationsWSDLNS()

getTargetSystemNS

protected abstract java.lang.String getTargetSystemNS()

getNotificationConsumerPortType

protected abstract javax.xml.namespace.QName getNotificationConsumerPortType()

getJobManagementPortType

protected abstract javax.xml.namespace.QName getJobManagementPortType()

getGetResourcePropertyPortType

protected abstract javax.xml.namespace.QName getGetResourcePropertyPortType()

getNotificationProducerPortType

protected abstract javax.xml.namespace.QName getNotificationProducerPortType()

getTargetSystemPortType

protected abstract javax.xml.namespace.QName getTargetSystemPortType()

getBPEL4WSNS

protected abstract java.lang.String getBPEL4WSNS()

getJSDLNS

protected abstract java.lang.String getJSDLNS()

getUnigridsNS

protected abstract java.lang.String getUnigridsNS()

getSubmitJobRequest

public Variable getSubmitJobRequest()

getSubmitJobResponse

public Variable getSubmitJobResponse()

getGetJobStateRequest

public Variable getGetJobStateRequest()

getGetJobStateResponse

public Variable getGetJobStateResponse()

getGetJobWorkingDirectoryResponse

public Variable getGetJobWorkingDirectoryResponse()

getJobManagement

public PartnerLink getJobManagement()

getJobState

public Variable getJobState()

getJobStatusChangeNotification

public Variable getJobStatusChangeNotification()

getNamespaces

public com.intel.gpe.util.xml.Namespaces getNamespaces()

getStartJobRequest

public Variable getStartJobRequest()

getStartJobResponse

public Variable getStartJobResponse()

getSubscribeToJobStatusChangeNotificationsRequest

public Variable getSubscribeToJobStatusChangeNotificationsRequest()

getSubscribeToJobStatusChangeNotificationsResponse

public Variable getSubscribeToJobStatusChangeNotificationsResponse()

getTargetSystem

public PartnerLink getTargetSystem()

emitCode

public void emitCode(Scope scope,
                     org.w3c.dom.Element target)
              throws java.lang.Exception

Description copied from interface: Action

Emit the piece of code corresponding to the current action.

Specified by:

emitCode in interface Action

Parameters:

scope - The variable scope of the workflow

target - The XML DOM element to append the action code to

Throws:

java.lang.Exception - In a case of error

getJobDefinition

public Variable getJobDefinition()

Get the variable where the job definition of the submitted job is stored

Returns:

The variable with job definition

getJobManagementPartnerLink

public PartnerLink getJobManagementPartnerLink()

Get the partner link to the created job management resource

Returns:

The partner link to the created job management resource

getWorkingDirectory

public Variable getWorkingDirectory()

Get the endpoint reference of the working directory storage resource

Returns:

The endpoint reference of the working directory

getJobStatus

public Variable getJobStatus()

Get the variable where the job's status is stored

Returns:

The variable with job's status

setTargetSystem

public void setTargetSystem(PartnerLink targetSystem)