本文整理了Java中io.syndesis.integration.model.YamlHelpers
类的一些代码示例,展示了YamlHelpers
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。YamlHelpers
类的具体详情如下:
包路径:io.syndesis.integration.model.YamlHelpers
类名称:YamlHelpers
暂无
代码示例来源:origin: io.syndesis.integration-runtime/model
public static SyndesisModel load(InputStream source) throws IOException {
return YamlHelpers.createObjectMapper().readValue(source, SyndesisModel.class);
}
}
代码示例来源:origin: io.syndesis.integration-runtime/model
@Test
public void testMarshal() throws Exception {
String expectedName = "cheese";
String expectedTrigger = "activemq:foo";
String expectedFunctionName = "io.syndesis.runtime.integration.example.Main::cheese";
String expectedEndpointUrl = "http://google.com/";
SyndesisModel expected = new SyndesisModel();
expected.createFlow().name(expectedName).endpoint(expectedTrigger).function(expectedFunctionName).endpoint(expectedEndpointUrl);
String yaml = YamlHelpers.createObjectMapper().writeValueAsString(expected);
LOG.info("Created YAML:\n{}", yaml);
try(InputStream is = new ByteArrayInputStream(yaml.getBytes(StandardCharsets.UTF_8))) {
SyndesisModel actual = YamlHelpers.load(is);
Flow actualFlow = SyndesisAssertions.assertFlow(actual, 0);
SyndesisAssertions.assertEndpointStep(actualFlow, 0, expectedTrigger);
SyndesisAssertions.assertFunctionStep(actualFlow, 1, expectedFunctionName);
SyndesisAssertions.assertEndpointStep(actualFlow, 2, expectedEndpointUrl);
}
}
}
代码示例来源:origin: io.syndesis.integration-runtime/runtime
protected SyndesisModel loadTestYaml() throws IOException {
String path = getClass().getName().replace('.', '/') + "-" + getTestMethodName() + ".yml";
LOG.info("Loading SyndesisModel flows from classpath at: " + path);
URL resource = getClass().getClassLoader().getResource(path);
Assertions.assertThat(resource).describedAs("Could not find " + path + " on the classpath!").isNotNull();
try (InputStream is = resource.openStream()) {
return YamlHelpers.load(is);
}
}
代码示例来源:origin: io.syndesis.integration-runtime/runtime
protected SyndesisModel loadModel() throws Exception {
try (InputStream is = ResourceHelper.resolveResourceAsInputStream(getContext().getClassResolver(), configurationUri)) {
return is == null
? new SyndesisModel()
: YamlHelpers.load(is);
}
}
代码示例来源:origin: io.syndesis.integration-runtime/model
@Test
public void testUnmarshal() throws Exception {
try (InputStream is = ModelUnmarshalTest.class.getResourceAsStream("/syndesis.yml")) {
SyndesisModel model = YamlHelpers.load(is);
List<Flow> rules = model.getFlows();
assertThat(rules).isNotEmpty();
for (Flow rule : rules) {
LOG.info("Loaded: " + rule);
}
Flow actualFlow1 = SyndesisAssertions.assertFlow(model, 0);
Flow actualFlow2 = SyndesisAssertions.assertFlow(model, 1);
assertThat(actualFlow1.getName()).describedAs("name").isEqualTo("thingy");
SyndesisAssertions.assertEndpointStep(actualFlow1, 0, "http://0.0.0.0:8080");
SyndesisAssertions.assertFunctionStep(actualFlow1, 1, "io.syndesis.integration.runtime.example.Main::cheese");
assertThat(actualFlow2.getName()).describedAs("name").isEqualTo("another");
SyndesisAssertions.assertEndpointStep(actualFlow2, 0, "http://0.0.0.0:8080");
SyndesisAssertions.assertEndpointStep(actualFlow2, 1, "activemq:whatnot");
}
}
}
代码示例来源:origin: io.syndesis.integration-runtime/runtime
public MarshallingTest(Step step) {
this.step = step;
this.mapper = YamlHelpers.createObjectMapper();
}
内容来源于网络,如有侵权,请联系作者删除!