gpt4 book ai didi

io.syndesis.integration.model.YamlHelpers.load()方法的使用及代码示例

转载 作者:知者 更新时间:2024-03-14 03:59:31 27 4
gpt4 key购买 nike

本文整理了Java中io.syndesis.integration.model.YamlHelpers.load()方法的一些代码示例,展示了YamlHelpers.load()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。YamlHelpers.load()方法的具体详情如下:
包路径:io.syndesis.integration.model.YamlHelpers
类名称:YamlHelpers
方法名:load

YamlHelpers.load介绍

暂无

代码示例

代码示例来源: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/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);
    }
  }
}

27 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com