org.trianacode.shiwaall.utils

Class BrokerUtils

java.lang.Object

org.trianacode.shiwaall.utils.BrokerUtils

public class BrokerUtils
extends java.lang.Object

Created by IntelliJ IDEA. User: Ian Harvey Date: 05/05/2012 Time: 12:55 To change this template use File | Settings | File Templates.

Constructor Summary

Constructors

Constructor and Description
BrokerUtils()

Method Summary

Methods

Modifier and Type	Method and Description
static void	addParentDetailsToSubWorkflow(org.shiwa.desktop.data.description.core.WorkflowImplementation impl, java.util.UUID runUUID, java.util.UUID parentID, java.lang.String jobID, java.lang.String jobInstID) Adds the parent details to sub workflow.
static java.lang.String	getJSONReply(java.lang.String url, java.lang.String uuid, java.lang.String execBundleName) Gets the jSON reply.
static java.io.File	getResultBundle(java.lang.String url, java.lang.String key) Gets the result bundle.
static Scheduler	getSchedulerForTaskGraph(TaskGraph taskGraph) Gets the scheduler for task graph.
static java.lang.String	getTimeStamp() Gets the time stamp.
static java.lang.String	postBundle(java.lang.String hostAddress, java.lang.String routingKey, java.lang.String execBundleName, java.io.File tempBundleFile) Post bundle.
static void	prepareSubworkflow(Task task, java.util.UUID runUUID, org.shiwa.desktop.data.description.core.WorkflowImplementation workflowImplementation) Prepare subworkflow.
static java.lang.String	waitForExec(java.lang.String url, int i, java.lang.String uuid, java.lang.String execBundleName) Wait for exec.

Methods inherited from class java.lang.Object

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

Constructor Detail

BrokerUtils

public BrokerUtils()

Method Detail

getTimeStamp

public static java.lang.String getTimeStamp()

Gets the time stamp.

Returns:

the time stamp

getResultBundle

public static java.io.File getResultBundle(java.lang.String url,
                           java.lang.String key)

Gets the result bundle.

Parameters:

url - the url

key - the key

Returns:

the result bundle

waitForExec

public static java.lang.String waitForExec(java.lang.String url,
                           int i,
                           java.lang.String uuid,
                           java.lang.String execBundleName)

Wait for exec.

Parameters:

url - the url

i - the i

uuid - the uuid

execBundleName - the exec bundle name

Returns:

the string

getJSONReply

public static java.lang.String getJSONReply(java.lang.String url,
                            java.lang.String uuid,
                            java.lang.String execBundleName)

Gets the jSON reply.

Parameters:

url - the url

uuid - the uuid

execBundleName - the exec bundle name

Returns:

the jSON reply

postBundle

public static java.lang.String postBundle(java.lang.String hostAddress,
                          java.lang.String routingKey,
                          java.lang.String execBundleName,
                          java.io.File tempBundleFile)

Post bundle.

Parameters:

hostAddress - the host address

routingKey - the routing key

execBundleName - the exec bundle name

tempBundleFile - the temp bundle file

Returns:

the string

addParentDetailsToSubWorkflow

public static void addParentDetailsToSubWorkflow(org.shiwa.desktop.data.description.core.WorkflowImplementation impl,
                                 java.util.UUID runUUID,
                                 java.util.UUID parentID,
                                 java.lang.String jobID,
                                 java.lang.String jobInstID)

Adds the parent details to sub workflow.

Parameters:

impl - the impl

runUUID - the run uuid

parentID - the parent id

jobID - the job id

jobInstID - the job inst id

getSchedulerForTaskGraph

public static Scheduler getSchedulerForTaskGraph(TaskGraph taskGraph)

Gets the scheduler for task graph.

Parameters:

taskGraph - the task graph

Returns:

the scheduler for task graph

prepareSubworkflow

public static void prepareSubworkflow(Task task,
                      java.util.UUID runUUID,
                      org.shiwa.desktop.data.description.core.WorkflowImplementation workflowImplementation)

Prepare subworkflow.

Parameters:

task - the task

runUUID - the run uuid

workflowImplementation - the workflow implementation