Package org.springframework.xd.module.options

Examples of org.springframework.xd.module.options.DefaultModuleOptionsMetadataResolver


    return mock(WriteableModuleRegistry.class);
  }

  @Bean
  public ModuleOptionsMetadataResolver moduleOptionsMetadataResolver() {
    return new DefaultModuleOptionsMetadataResolver();
  }
View Full Code Here


  @Test
  public void testInvalidModules() {
    String config = "test | foo--x=13";
    XDStreamParser parser = new XDStreamParser(testRepository, mock(ModuleRegistry.class),
        new DefaultModuleOptionsMetadataResolver());
    try {
      parser.parse("t", config, stream);
      fail(config + " is invalid. Should throw exception");
    }
    catch (Exception e) {
View Full Code Here

      return new ResourceModuleRegistry("file:../modules");
    }

    @Bean
    public ModuleOptionsMetadataResolver moduleOptionsMetadataResolver() {
      return new DefaultModuleOptionsMetadataResolver();
    }
View Full Code Here

    }


    @Bean
    public ModuleOptionsMetadataResolver moduleOptionsMetadataResolver() {
      return new DefaultModuleOptionsMetadataResolver();
    }
View Full Code Here

      return new XDStreamParser(moduleRegistry(), moduleOptionsMetadataResolver());
    }

    @Bean
    public ModuleOptionsMetadataResolver moduleOptionsMetadataResolver() {
      return new DefaultModuleOptionsMetadataResolver();
    }
View Full Code Here

  private String moduleName = "siDslModule";

  @Test
  public void testModuleProperties() {
    ModuleOptionsMetadataResolver moduleOptionsMetadataResolver = new DefaultModuleOptionsMetadataResolver();
    String resource = "classpath:/";
    ModuleDefinition definition = ModuleDefinitions.simple(moduleName, processor, resource);
    ModuleOptionsMetadata metadata = moduleOptionsMetadataResolver.resolve(definition);

    assertThat(
        metadata,
        containsInAnyOrder(moduleOptionNamed("prefix"), moduleOptionNamed("suffix"),
            moduleOptionNamed("prefixOnly")));
View Full Code Here

  private XDStreamParser parser;

  @Before
  public void setup() {
    parser = new XDStreamParser(moduleRegistry(), new DefaultModuleOptionsMetadataResolver());
  }
View Full Code Here

  @Test
  public void tap() throws Exception {
    StreamDefinitionRepository streamRepo = mock(StreamDefinitionRepository.class);
    parser = new XDStreamParser(streamRepo, moduleRegistry(),
        new DefaultModuleOptionsMetadataResolver());
    when(streamRepo.findOne("xxx")).thenReturn(new StreamDefinition("xxx", "http | file"));
    List<ModuleDescriptor> requests = parser.parse("test", "tap:stream:xxx.http > file", stream);
    assertEquals(1, requests.size());
    assertEquals("tap:stream:xxx.http.0", requests.get(0).getSourceChannelName());
    assertEquals(ModuleType.sink, requests.get(0).getType());
View Full Code Here

TOP

Related Classes of org.springframework.xd.module.options.DefaultModuleOptionsMetadataResolver

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.