Package edu.indiana.extreme.xbaya.ode

Examples of edu.indiana.extreme.xbaya.ode.ODEClient

32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
    ExperimentUtils experimentUtils = new ExperimentUtils();
   
    //FIXME: remove this, they should be passed
    LeadContextHeader leadContextHeader = experimentUtils.createLeadContextHeader(expBldrWorkflow);
   
    ODEClient xbayaODEClient = new ODEClient();
   
    String workflowTemplateName = expBldrWorkflow.getName();
    System.out.println("Workflow String  @@@@@@@@@@@@" + workflowTemplateName);
  //    Workflow xBayaWorkflow = xbayaODEClient.getWorkflow(URI.create(context.getXRegistryUrl()), context.getGssCredential(), workflowTemplateName);
//    TODO: Extract all inputs from front end and stuff into xbaya workflow object
   
  //  List<WSComponentPort> workflowInputs = xbayaODEClient.getInputs(xBayaWorkflow);
    Workflow xBayaWorkflow = null;
   
    try {
      String resource =  context.getRegistryClient().getOGCEResource(new QName(WORKFLOWQNAME,workflowTemplateName), ResourceType.WorkflowTemplate.toString(), null);
      XmlElement xwf = XMLUtil.stringToXmlElement(resource);
      xBayaWorkflow = new Workflow(xwf);
//   
    } catch (Exception e) {
      // TODO Auto-generated catch block
      e.printStackTrace();
    }
   
    xbayaODEClient.invoke(xBayaWorkflow, context.getGssCredential(), dscUri, odeUrl.toString(), leadContextHeader);
  }
View Full Code Here
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
    } catch (Exception e1) {
      // TODO Auto-generated catch block
      e1.printStackTrace();
    }

    ODEClient xbayaRegistryClient = new ODEClient();
   
//    if (workflowTemplateName.startsWith("http://extreme.indiana.edu/lead/workflow/")){
//      QName workflowQName = new QName(workflowTemplateName);
//      xBayaWorkflow = xbayaRegistryClient.getWorkflow(URI.create(xRegistryUrl), credential, workflowQName);
//    } else {
//      xBayaWorkflow = xbayaRegistryClient.getWorkflow(URI.create(xRegistryUrl), credential, workflowTemplateName);
//    } 
   
    if (workflowTemplateName.startsWith("http://extreme.indiana.edu/lead/workflow/")){
      String[] tokens = workflowTemplateName.split("/");
      workflowTemplateName = tokens[tokens.length - 1];
    }  
    //Fetch the required elements and load into to lighter experiment builder workflow model
    try {
      xBayaWorkflow = xbayaRegistryClient.getWorkflow(URI.create(context.getXRegistryUrl()), cred, workflowTemplateName);
     
      if (xBayaWorkflow != null){
        expBldrWorkflow.setId(xBayaWorkflow.getUniqueWorkflowName().toString());
        expBldrWorkflow.setName(xBayaWorkflow.getName());
        expBldrWorkflow.setDescription(xBayaWorkflow.getDescription());
        expBldrWorkflow.setWorkflowImage(xBayaWorkflow.getImage()); 
//        for (WSComponentPort wsComponentPort : inputs) {
//          wsComponentPort.setDefaultValue("<whateverxml/>");
//          wsComponentPort.getDescription();
//        }
       
        // Fetch All Workflow Inputs
        List<WSComponentPort> workflowInputs = xbayaRegistryClient.getInputs(xBayaWorkflow);
        LinkedList<Pair<WSComponentPort, String>> workflowInputExtensionPairs = new LinkedList<Pair<WSComponentPort, String>>();
       
        //Iterate through all inputs and determine extensions and stuff them into experiment builder workflow object
        for (WSComponentPort workflowInput : workflowInputs) {
          String inputExtension = null;
View Full Code Here
58
59
60
61
62
63
64
65
66
67
68
    } catch (ComponentException e1) {
      // TODO Auto-generated catch block
      e1.printStackTrace();
    }
    System.err.println("Setting Input values");
    List<InputNode> inputNodes = new ODEClient().getInputNodes(workflow);
    for (InputNode inputNode : inputNodes) {
      for (NameValue input : inputs) {
        if (inputNode.getName().equals(input.getName())) {
          inputNode.setDefaultValue(input.getValue());
          break;
View Full Code Here
254
255
256
257
258
259
260
261
262
263
264
265
266
267
    if(resource == null){
      throw new Exception("Not able to find resource in Xregistry");
    }
    XmlElement xwf = XMLUtil.stringToXmlElement(resource);
    Workflow xbayaworkflow = new Workflow(xwf);
    ODEClient xbayaRegistryClient = new ODEClient();
    workflow.setName(xbayaworkflow.getName());
    workflow.setDescription(xbayaworkflow.getDescription());
    workflow.setWorkflowImage(xbayaworkflow.getImage());
    List<WSComponentPort> workflowInputs = xbayaRegistryClient.getInputs(xbayaworkflow);
    workflow.setWorkflowInputs(xbayaworkflow.getInputs());
    workflow.setWorkflow(xbayaworkflow);
    return workflow;
  }
View Full Code Here
TOP

Related Classes of edu.indiana.extreme.xbaya.ode.ODEClient

  • edu.indiana.dde.mylead.agent.AgentPortType
  • edu.indiana.dde.mylead.agent.xmlbeans.CollectionType
  • edu.indiana.dde.mylead.agent.xmlbeans.CreateCollectionsRequestType
  • edu.indiana.dde.mylead.agent.xmlbeans.CreateExperimentsRequestDocument
  • edu.indiana.dde.mylead.agent.xmlbeans.OperationResponseDocument
  • edu.indiana.extreme.lead.metadata.LEADResourceType
  • edu.indiana.extreme.lead.metadata.ThemeType
  • edu.indiana.extreme.lead.metadata.util.MinimalLEADMetadata
  • edu.indiana.extreme.xbaya.component.dynamic.GenericSubWorkflowComponent
  • edu.indiana.extreme.xbaya.component.SubWorkflowComponent
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.