LocalExecution extends AbstractExecution implements ResultListener { @Override public void start() { MonitorManager.getInstance().addObserver(executionMonitor); facade.addResultListener(this); facade.fire(); try { if (DataBundles.hasInputs(getDataBundle())) { Path inputs = DataBundles.getInputs(getDataBundle()); for (Entry<String, DataflowInputPort> inputPort : inputPorts .entrySet()) { String portName = inputPort.getKey(); Path port = DataBundles.getPort(inputs, portName); if (!DataBundles.isMissing(port)) { T2Reference identifier = referenceService.register( DataBundles.resolve(port, ResolveOptions.BYTES), inputPort.getValue() .getDepth(), true, null); int[] index = new int[] {}; WorkflowDataToken token = new WorkflowDataToken("", index, identifier, facade.getContext()); try { facade.pushData(token, portName); } catch (TokenOrderException e) { logger.log(SEVERE, "Unable to push data for input " + portName, e); } } } } } catch (IOException|UncheckedIOException e) { logger.log(SEVERE, "Error getting input data", e); } } LocalExecution(WorkflowBundle workflowBundle, Workflow workflow,
			Profile profile, Bundle dataBundle,
			ReferenceService referenceService, Edits edits,
			ActivityService activityService,
			DispatchLayerService dispatchLayerService); @Override void delete(); @Override void start(); @Override void pause(); @Override void resume(); @Override void cancel(); @Override ProcessorReport createProcessorReport(
			org.apache.taverna.scufl2.api.core.Processor processor); @Override ActivityReport createActivityReport(
			org.apache.taverna.scufl2.api.activity.Activity activity); @Override void resultTokenProduced(WorkflowDataToken token, String portName);  }
@Test @Ignore public void testStart() { }