• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号
登陆 注册
描述文字

Java Configuration类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中org.apache.taverna.scufl2.api.configurations.Configuration类的典型用法代码示例。如果您正苦于以下问题：Java Configuration类的具体用法？Java Configuration怎么用？Java Configuration使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



Configuration类属于org.apache.taverna.scufl2.api.configurations包，在下文中一共展示了Configuration类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: addNewProvider

import org.apache.taverna.scufl2.api.configurations.Configuration; //导入依赖的package包/类
protected void addNewProvider(Configuration configurationBean) {
	ConfigurableServiceProvider cloned = (ConfigurableServiceProvider) confProvider
			.newInstance();
	try {
		cloned.configure(configurationBean);
		getServiceDescriptionRegistry().addObserver(
				new CheckAddedCorrectlyObserver(cloned));
		getServiceDescriptionRegistry().addServiceDescriptionProvider(
				cloned);
	} catch (Exception ex) {
		logger.warn("Can't configure provider " + cloned + " using "
				+ configurationBean, ex);
		showMessageDialog(owner, "Can't configure service provider "
				+ cloned.getName(), "Can't add service provider",
				ERROR_MESSAGE);
	}
}
开发者ID:apache，项目名称:incubator-taverna-workbench，代码行数:18，代码来源:AddServiceProviderAction.java


示例2: defineEditsForConfiguration

import org.apache.taverna.scufl2.api.configurations.Configuration; //导入依赖的package包/类
private void defineEditsForConfiguration(Workflow workflow,
		OutputWorkflowPort port, WorkflowBundle workflowBundle,
		Activity activity, Configuration c) {
	List<Edit<?>> edits = nestedPortEdit.getChildEdits();
	JsonNode nested = c.getJson().get("nestedWorkflow");
	Workflow nestedWorkflow = workflowBundle.getWorkflows().getByName(
			nested.asText());
	if (nestedWorkflow != workflow)
		return;

	OutputActivityPort activityPort = activity.getOutputPorts().getByName(
			port.getName());
	edits.add(new RemoveChildEdit<>(activity, activityPort));
	for (ProcessorBinding processorBinding : scufl2Tools
			.processorBindingsToActivity(activity))
		for (ProcessorOutputPortBinding portBinding : processorBinding
				.getOutputPortBindings())
			if (portBinding.getBoundActivityPort() == activityPort) {
				OutputProcessorPort processorPort = portBinding
						.getBoundProcessorPort();
				edits.add(new RemoveProcessorOutputPortEdit(
						processorBinding.getBoundProcessor(), processorPort));
				edits.add(new RemoveChildEdit<>(processorBinding,
						portBinding));
			}
}
开发者ID:apache，项目名称:incubator-taverna-workbench，代码行数:27，代码来源:RemoveWorkflowOutputPortEdit.java


示例3: initialise

import org.apache.taverna.scufl2.api.configurations.Configuration; //导入依赖的package包/类
private void initialise() {
	if (panel == null) {
		panel = createPanel();
	} else {
		panel.removeAll();
	}

	JTextArea textArea = new ReadOnlyTextArea();
	textArea.setEditable(false);
	String maxJobs = "1";
	for (Configuration configuration : scufl2Tools.configurationsFor(processor, selectionManager.getSelectedProfile())) {
		JsonNode processorConfig = configuration.getJson();
		if (processorConfig.has("parallelize")) {
			JsonNode parallelizeConfig = processorConfig.get("parallelize");
			if (parallelizeConfig.has("maximumJobs")) {
				maxJobs = parallelizeConfig.get("maximumJobs").asText();
			}
		}
	}
	textArea.setText("The maximum number of jobs is " + maxJobs);
	textArea.setBackground(panel.getBackground());
	panel.add(textArea, BorderLayout.CENTER);
	revalidate();
}
开发者ID:apache，项目名称:incubator-taverna-workbench，代码行数:25，代码来源:ParallelizeContextualView.java


示例4: testCompletenessOfSpecifiedConfigurations

import org.apache.taverna.scufl2.api.configurations.Configuration; //导入依赖的package包/类
@Test
public void testCompletenessOfSpecifiedConfigurations() {
	DummyProfile profile = new DummyProfile();
	// The fields will default to null
	profile.setConfigurations(new NamedSet<Configuration>());
	
	CorrectnessValidator cv = new CorrectnessValidator();
	ReportCorrectnessValidationListener rcvl = new ReportCorrectnessValidationListener();
	
	cv.checkCorrectness(profile, true, rcvl);
	
	Set<NullFieldProblem> nullFieldProblems = rcvl.getNullFieldProblems();
	boolean problem = false;
	for (NullFieldProblem nlp : nullFieldProblems) {
		if (nlp.getBean().equals(profile) && nlp.getFieldName().equals("configurations")) {
			problem = true;
		}
	}
	assertFalse(problem);
	
}
开发者ID:apache，项目名称:incubator-taverna-language，代码行数:22，代码来源:TestProfile.java


示例5: testIdenticalConfigurableTypes

import org.apache.taverna.scufl2.api.configurations.Configuration; //导入依赖的package包/类
@Test
public void testIdenticalConfigurableTypes() {
	Configuration configuration = new Configuration();
	Activity a = new Activity();
	URI tavernaUri = null;
	try {
		tavernaUri = new URI("http://www.taverna.org.uk");
	} catch (URISyntaxException e) {
		return;
	}
	configuration.setConfigures(a);
	configuration.setType(tavernaUri);
	a.setType(tavernaUri);
	
	CorrectnessValidator cv = new CorrectnessValidator();
	ReportCorrectnessValidationListener rcvl = new ReportCorrectnessValidationListener();
	
	cv.checkCorrectness(configuration, false, rcvl);
	
	Set<MismatchConfigurableTypeProblem> mismatchConfigurableTypeProblems = rcvl.getMismatchConfigurableTypeProblems();
	assertEquals(0, mismatchConfigurableTypeProblems.size());
}
开发者ID:apache，项目名称:incubator-taverna-language，代码行数:23，代码来源:TestConfiguration.java


示例6: testEqualConfigurableTypes

import org.apache.taverna.scufl2.api.configurations.Configuration; //导入依赖的package包/类
@Ignore
public void testEqualConfigurableTypes() {
	Configuration configuration = new Configuration();
	Activity a = new Activity();
	URI tavernaUri = null;
	URI tavernaUri2 = null;
	try {
		tavernaUri = new URI("http://www.taverna.org.uk");
		tavernaUri2 = new URI("http://www.taverna.org.uk");
	} catch (URISyntaxException e) {
		return;
	}
	configuration.setConfigures(a);
	configuration.setType(tavernaUri);
	a.setType(tavernaUri2);
	
	CorrectnessValidator cv = new CorrectnessValidator();
	ReportCorrectnessValidationListener rcvl = new ReportCorrectnessValidationListener();
	
	cv.checkCorrectness(configuration, false, rcvl);
	
	Set<MismatchConfigurableTypeProblem> mismatchConfigurableTypeProblems = rcvl.getMismatchConfigurableTypeProblems();
	assertEquals(0, mismatchConfigurableTypeProblems.size());
}
开发者ID:apache，项目名称:incubator-taverna-language，代码行数:25，代码来源:TestConfiguration.java


示例7: testCompletenessOfMissingConfigures

import org.apache.taverna.scufl2.api.configurations.Configuration; //导入依赖的package包/类
@Test
public void testCompletenessOfMissingConfigures() {
	Configuration configuration = new Configuration();
       configuration.setType(URI.create("http://www.example.com/"));
       configuration.setJson("{ \"hello\": 1337  }");
	
	CorrectnessValidator cv = new CorrectnessValidator();
	ReportCorrectnessValidationListener rcvl = new ReportCorrectnessValidationListener();
	
	cv.checkCorrectness(configuration, true, rcvl);
	
	Set<NullFieldProblem> nullFieldProblems = rcvl.getNullFieldProblems();
	assertFalse(nullFieldProblems.isEmpty()); // only done when completeness check
	
	boolean fieldProblem = false;
	for (NullFieldProblem nlp : nullFieldProblems) {
		if (nlp.getBean().equals(configuration) && nlp.getFieldName().equals("configures")) {
			fieldProblem = true;
		}
	}
	assertTrue(fieldProblem);
}
开发者ID:apache，项目名称:incubator-taverna-language，代码行数:23，代码来源:TestConfiguration.java


示例8: configurationNotAddedTwice

import org.apache.taverna.scufl2.api.configurations.Configuration; //导入依赖的package包/类
/**
 * Similar bug to {@link DataLinkCompareTest#dataLinkNotAddedTwice()}
 */
@Test
public void configurationNotAddedTwice() throws Exception {
	Configuration c1a = new Configuration("c1");
	Profile p1 = new Profile("p1");
	p1.getConfigurations().add(c1a);		
	c1a.setParent(p1);
	p1.getConfigurations().add(c1a);
	
	
	Configuration c1b = new Configuration("c1");
	Profile p2 = new Profile("p2");
	p2.getConfigurations().add(c1b);		
	c1b.setParent(p2);
	p2.getConfigurations().add(c1b);
	
	
	WorkflowBundle bundle = new WorkflowBundle();
	p1.setParent(bundle);
	p2.setParent(bundle);
	new Scufl2Tools().setParents(bundle);
	assertEquals(1, p1.getConfigurations().size());
	assertEquals(1, p2.getConfigurations().size());
	
}
开发者ID:apache，项目名称:incubator-taverna-language，代码行数:28，代码来源:ConfigurationTest.java


示例9: parseConfiguration

import org.apache.taverna.scufl2.api.configurations.Configuration; //导入依赖的package包/类
@Override
public Configuration parseConfiguration(T2FlowParser t2FlowParser,
		ConfigBean configBean, ParserState parserState) throws ReaderException {
	StringConstantConfig strConfig = unmarshallConfig(t2FlowParser,
			configBean, "xstream", StringConstantConfig.class);
	String value = strConfig.getValue();
	if (value == null)
		throw new ReaderException("String constant configuration has no value set");
	Configuration configuration = new Configuration();
	ObjectNode json = (ObjectNode) configuration.getJson();
	configuration.setType(CONSTANT.resolve("#Config"));
	json.put("string", value);
	
	Activity activity = parserState.getCurrentActivity();
	OutputActivityPort valuePort = new OutputActivityPort(activity, VALUE);
	valuePort.setDepth(0);
	valuePort.setGranularDepth(0);
	return configuration;
}
开发者ID:apache，项目名称:incubator-taverna-language，代码行数:20，代码来源:StringConstantActivityParser.java


示例10: refreshView

import org.apache.taverna.scufl2.api.configurations.Configuration; //导入依赖的package包/类
/**
 * Typically called when the activity configuration has changed.
 */
@Override
public void refreshView() {
	Configuration configuration = scufl2Tools.configurationFor(activity, activity.getParent());
	JsonNode json = configuration.getJson();

	// Set XPath Expression
	tfXPathExpression.setText(json.get("xpathExpression").asText());

	// Populate Namespace Mappings
	xpathNamespaceMappingsTableModel.getDataVector().removeAllElements();
	if (json.has("xpathNamespaceMap")) {
		for (JsonNode mapping : json.get("xpathNamespaceMap")) {
			xpathNamespaceMappingsTableModel.addRow(new Object[] {
					mapping.get("prefix").asText(), mapping.get("uri").asText() });
		}
	}
}
开发者ID:apache，项目名称:incubator-taverna-workbench-common-activities，代码行数:21，代码来源:XPathActivityMainContextualView.java


示例11: doDelete

import org.apache.taverna.scufl2.api.configurations.Configuration; //导入依赖的package包/类
private void doDelete(final Component chosenComponent) {
	if (chosenComponent == null) {
		showMessageDialog(null, WHAT_COMPONENT_MSG,
				COMPONENT_PROBLEM_TITLE, ERROR_MESSAGE);
	} else if (componentIsInUse(chosenComponent)) {
		showMessageDialog(null, OPEN_COMPONENT_MSG,
				COMPONENT_PROBLEM_TITLE, ERROR_MESSAGE);
	} else if (showConfirmDialog(null,
			format(CONFIRM_MSG, chosenComponent.getName()), CONFIRM_TITLE,
			YES_NO_OPTION) == YES_OPTION)
		new SwingWorker<Configuration, Object>() {
			@Override
			protected Configuration doInBackground() throws Exception {
				return deleteComponent(chosenComponent);
			}

			@Override
			protected void done() {
				refresh(chosenComponent, this);
			}
		}.execute();
}
开发者ID:apache，项目名称:incubator-taverna-plugin-component，代码行数:23，代码来源:ComponentDeleteAction.java


示例12: parseConfiguration

import org.apache.taverna.scufl2.api.configurations.Configuration; //导入依赖的package包/类
@Override
public Configuration parseConfiguration(T2FlowParser t2FlowParser,
		ConfigBean configBean, ParserState parserState) throws ReaderException {
	DataflowConfig dataflowConfig = unmarshallConfig(t2FlowParser,
			configBean, "dataflow", DataflowConfig.class);
	Configuration configuration = new Configuration();
	configuration.setType(nestedUri.resolve("#Config"));		

	String wfId = dataflowConfig.getRef();
	URI wfUri = WORKFLOW_ROOT.resolve(wfId + "/");
	Workflow wf = (Workflow) getUriTools().resolveUri(wfUri, parserState.getCurrentWorkflowBundle());		
	if (wf == null)
        throw new ReaderException("Can't find nested workflow with id " + wfId);
	ObjectNode json = configuration.getJsonAsObjectNode();
	json.put("nestedWorkflow", wf.getName());
	return configuration;
}
开发者ID:apache，项目名称:incubator-taverna-language，代码行数:18，代码来源:DataflowActivityParser.java


示例13: parseConfiguration

import org.apache.taverna.scufl2.api.configurations.Configuration; //导入依赖的package包/类
@Override
public Configuration parseConfiguration(T2FlowParser t2FlowParser,
		ConfigBean configBean, ParserState parserState)
		throws ReaderException {
	ComponentConfig config = unmarshallConfig(t2FlowParser, configBean,
			"xstream", ComponentConfig.class);

	Configuration configuration = new Configuration();
	configuration.setParent(parserState.getCurrentProfile());

	ObjectNode json = (ObjectNode) configuration.getJson();
	configuration.setType(ACTIVITY_URI.resolve("#Config"));

	json.put("registryBase", config.getRegistryBase());
	json.put("familyName", config.getFamilyName());
	json.put("componentName", config.getComponentName());
	if (config.getComponentVersion() != null)
		json.put("componentVersion", (int) config.getComponentVersion());

	return configuration;
}
开发者ID:apache，项目名称:incubator-taverna-language，代码行数:22，代码来源:ComponentActivityParser.java


示例14: checkOneConfiguration

import org.apache.taverna.scufl2.api.configurations.Configuration; //导入依赖的package包/类
private void checkOneConfiguration(InputWorkflowPort workflowPort,
		Integer depth, Workflow workflow, WorkflowBundle workflowBundle,
		Activity activity, Configuration c) {
	JsonNode nested = c.getJson().get("nestedWorkflow");
	Workflow nestedWorkflow = workflowBundle.getWorkflows().getByName(
			nested.asText());
	if (nestedWorkflow != workflow)
		return;

	ActivityPort activityPort = activity.getInputPorts().getByName(
			workflowPort.getName());
	activityPort.setDepth(depth);
	for (ProcessorBinding binding : scufl2Tools
			.processorBindingsToActivity(activity))
		for (ProcessorInputPortBinding portBinding : binding
				.getInputPortBindings())
			if (portBinding.getBoundActivityPort() == activityPort) {
				InputProcessorPort processorPort = portBinding
						.getBoundProcessorPort();
				processorPort.setDepth(depth);
			}
}
开发者ID:apache，项目名称:incubator-taverna-workbench，代码行数:23，代码来源:ChangeDepthEdit.java


示例15: changeActivityPortName

import org.apache.taverna.scufl2.api.configurations.Configuration; //导入依赖的package包/类
private void changeActivityPortName(WorkflowPort workflowPort,
		String oldName, String newName, Workflow workflow,
		WorkflowBundle workflowBundle, Activity activity, Configuration c) {
	JsonNode nested = c.getJson().get("nestedWorkflow");
	Workflow nestedWorkflow = workflowBundle.getWorkflows().getByName(
			nested.asText());
	if (nestedWorkflow != workflow)
		return;

	ActivityPort activityPort;
	if (workflowPort instanceof InputPort) {
		activityPort = activity.getInputPorts().getByName(oldName);
		changeProcessorInputPortName(oldName, newName, activity,
				activityPort);
	} else {
		activityPort = activity.getOutputPorts().getByName(oldName);
		changeProcessorOutputPortName(oldName, newName, activity,
				activityPort);
	}
	activityPort.setName(newName);
}
开发者ID:apache，项目名称:incubator-taverna-workbench，代码行数:22，代码来源:RenameEdit.java


示例16: configureActivity

import org.apache.taverna.scufl2.api.configurations.Configuration; //导入依赖的package包/类
public void configureActivity(WorkflowBundle workflowBundle, Activity activity,
		ObjectNode json, List<ActivityPortConfiguration> inputPorts,
		List<ActivityPortConfiguration> outputPorts) {
	try {
		List<Edit<?>> editList = new ArrayList<Edit<?>>();
		Profile profile = activity.getParent();
		List<ProcessorBinding> processorBindings = scufl2Tools
				.processorBindingsToActivity(activity);
		Configuration configuration = scufl2Tools.configurationFor(activity, profile);
		editList.add(new ChangeJsonEdit(configuration, json));

		configurePorts(activity, editList, processorBindings, inputPorts, PortType.INPUT);
		configurePorts(activity, editList, processorBindings, outputPorts, PortType.OUTPUT);
		editManager.doDataflowEdit(workflowBundle, new CompoundEdit(editList));
	} catch (IllegalStateException | EditException e) {
		logger.error(e);
	}
}
开发者ID:apache，项目名称:incubator-taverna-workbench，代码行数:19，代码来源:ActivityConfigurationDialog.java


示例17: whichLayers

import org.apache.taverna.scufl2.api.configurations.Configuration; //导入依赖的package包/类
@Test
public void whichLayers() throws Exception {
	Processor parallelise = processors.getByName("retries");
	// As inspected in /scufl2-t2flow/src/test/resources/dispatchlayers-xsd.t2flow

	//		List<String> expectedNames = Arrays.asList(PARALLELIZE, ERRORBOUNCE, FAILOVER, RETRY, INVOKE);
	// NOTE: Only those with configuration are present
	List<String> expectedNames = Arrays.asList(RETRY);
       
	Configuration config = scufl2Tools.configurationFor(parallelise, profile);
	ObjectNode json = config.getJsonAsObjectNode();
       for (String name : expectedNames) {
	    assertTrue("Could not find config for dispatch layer " + name, 
	            json.has(name)); 		}
	assertEquals("Additional dispatch layer configurations found", 
	        expectedNames.size(), json.size());

}
开发者ID:apache，项目名称:incubator-taverna-language，代码行数:19，代码来源:TestDispatchLayerParsing.java


示例18: simpleFasta

import org.apache.taverna.scufl2.api.configurations.Configuration; //导入依赖的package包/类
@Test
public void simpleFasta() throws Exception {
    URL wfResource = getClass().getResource(WF_SIMPLE_FASTA);
    assertNotNull("Could not find workflow " + WF_SIMPLE_FASTA,
            wfResource);
    T2FlowParser parser = new T2FlowParser();
    parser.setValidating(true);
    // parser.setStrict(true);
    WorkflowBundle wfBundle = parser.parseT2Flow(wfResource.openStream());

    Profile p = wfBundle.getMainProfile();
    for (Configuration c : p.getConfigurations()) {
        System.out.println(c.getConfigures());
        System.out.println(c.getJson());
    }
}
开发者ID:apache，项目名称:incubator-taverna-language，代码行数:17，代码来源:TestFastaWorkflow.java


示例19: parseScuflObject

import org.apache.taverna.scufl2.api.configurations.Configuration; //导入依赖的package包/类
@Override
public void parseScuflObject(Object o) {
	StringconstantType sc = (StringconstantType) o;
	Configuration configuration = new Configuration();
	configuration.setParent(getParserState().getCurrentProfile());
	configuration.setType(CONSTANT.resolve("#Config"));
	((ObjectNode) configuration.getJson()).put("string", sc.getValue());

	Activity activity = new Activity();
	getParserState().setCurrentActivity(activity);
	activity.setParent(getParserState().getCurrentProfile());
	activity.setType(CONSTANT);
	OutputActivityPort valuePort = new OutputActivityPort(activity, VALUE);
	valuePort.setDepth(0);
	valuePort.setGranularDepth(0);
	configuration.setConfigures(activity);

	ProcessorBinding pb = new ProcessorBinding();
	pb.setParent(getParserState().getCurrentProfile());
	pb.setBoundProcessor(getParserState().getCurrentProcessor());
	pb.setBoundActivity(activity);
}
开发者ID:apache，项目名称:incubator-taverna-language，代码行数:23，代码来源:StringConstantExtensionParser.java


示例20: actionPerformed

import org.apache.taverna.scufl2.api.configurations.Configuration; //导入依赖的package包/类
/**
 * If the localworker has not been changed it pops up a {@link JOptionPane} warning the user
 * that they change things at their own risk. Otherwise just show the config view
 */
public void actionPerformed(ActionEvent e) {
	Object[] options = { "Continue", "Cancel" };
	Configuration configuration = scufl2Tools.configurationFor(activity, activity.getParent());
	JsonNode json = configuration.getJson();
	if (!json.get("isAltered").booleanValue()) {
		int n = JOptionPane
				.showOptionDialog(
						null,
						"Changing the properties of a Local Worker may affect its behaviour. Do you want to continue?",
						"WARNING", JOptionPane.YES_NO_OPTION, JOptionPane.QUESTION_MESSAGE,
						null, // do not use a
						// custom Icon
						options, options[0]);

		if (n == 0) {
			// continue was clicked so prepare for config
			openDialog();
		} else {
			// do nothing
		}
	} else {
		openDialog();
	}
}
开发者ID:apache，项目名称:incubator-taverna-workbench-common-activities，代码行数:29，代码来源:LocalworkerActivityConfigurationAction.java



注：本文中的org.apache.taverna.scufl2.api.configurations.Configuration类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花
握手
雷人
路过
鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
More+
上一篇：
Java ZonedDateTimeSerializer类代码示例发布时间：2022-05-22
下一篇：
Java DefaultHttpResponseParser类代码示例发布时间：2022-05-22
热门推荐
More+
热门话题
More+
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服（服务时间 9:00～18:00）

在线QQ客服
地址：深圳市南山区西丽大学城创智工业园
电邮：jeky_zhao#qq.com
移动电话：139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap