tassl.application.cometcloud.sample
Class AppWorker

java.lang.Object
  tassl.application.cometcloud.WorkflowMeteorGenericWorker
      tassl.application.cometcloud.sample.AppWorker

All Implemented Interfaces:

tassl.automate.meteor.application.MeteorWorkerFramework, tassl.automate.meteor.MeteorNotifier, tassl.automate.programmodel.masterworker.WorkerFramework

public class AppWorker
extends WorkflowMeteorGenericWorker

Field Summary

Fields inherited from class tassl.application.cometcloud.WorkflowMeteorGenericWorker

sender

Constructor Summary

AppWorker()

Method Summary

void	cancelJob()
java.lang.Object	computeTaskSpecific(java.lang.Object dataobj, WorkflowTaskTuple tasktuple) This method is called to compute the task

Methods inherited from class tassl.application.cometcloud.WorkflowMeteorGenericWorker

computeTask, consumeTask, getAppName, getFile, getInitialTaskCount, getMasterPort, getPeerIP, getRequirement, getResultAddress, getStageID, getTemplateQuery, getWfManagerName, getWorkerid, getWorkflowID, loadParams, MeteorGenericWorker, meteorNotifyNode, meteorSubscribe, meteorUnsubscribe, putFile, quit, sendResultToMaster, setAppName, setCometEnv, setInitialTaskCount, setMeteorEnv, setPeerIP, setRequirement, setResultAddress, setResultPort, setStageID, setTaskids, setWfManagerName, setWorkflowID, startWorker, uploadResults

Methods inherited from class java.lang.Object

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

Constructor Detail

AppWorker

public AppWorker()

Method Detail

computeTaskSpecific

public java.lang.Object computeTaskSpecific(java.lang.Object dataobj,
                                            WorkflowTaskTuple tasktuple)

This method is called to compute the task

Specified by:

computeTaskSpecific in class WorkflowMeteorGenericWorker

Parameters:

dataobj - It is the data associated to the task. The one send from the master

tasktuple - TaskTuple object with the properties of the task.

Returns:

Object result data that will be attached to the task result. The object has to be serializable.

cancelJob

public void cancelJob()

Specified by:

cancelJob in class WorkflowMeteorGenericWorker