JOpera for Eclipse

This example should be used in conjunction with the dag.oml example. It will call the DAG process through the new JOpera REST API and wait for it to finish before it prints out its output. The URL points to the DAG process and the execution time of its tasks is passed as input parameter.

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.MalformedURLException;
import java.net.URL;
import java.net.URLConnection;


public class JOperaClient {

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		try {
	//setup the URL of the process to run
		URL url = new URL("http://localhost:8080/rest/dag/DAG/1.0/");
			
	//input parameter values should be CGI-URL Encoded
	        String output = callProcess(url, "time=1234");

        //this will contain the ID, final state of the process, and its output parameter values
	        System.out.println(output);
			
		} catch (MalformedURLException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		}

	}

	private static String callProcess(URL url, String input) throws IOException {

	//synchronous blocking calls (where the response arrives once the process has finished)
		if (input != null & input.length()>0)
			input = "Action=run&" + input;
		else
			input = "Action=run";
		
	// Send the request
		URLConnection conn = url.openConnection();
		conn.setDoOutput(true);
		OutputStreamWriter wr = new OutputStreamWriter(conn.getOutputStream());
		wr.write(input);
		wr.flush();
   
	// Wait to read the response
		String output = "";
		String line;
		BufferedReader rd = new BufferedReader(new InputStreamReader(conn.getInputStream()));
		while ((line = rd.readLine()) != null) {
		    output += line + "\n";
		}
		wr.close();
		rd.close();
		return output;
	}

}