与示例推特转换器类似,我已经创建了一个Spring XD模块。 Spring文档说您可以在spring-module.properties下使用spring-module.xmlsrc/main/resources/config/配置,也可以使用专用的ModuleConfiguration.java文件来定义Bean。但是,如果仅使用后者,它将无法运行。 XD抱怨无法确定模块类型。

如果添加spring-modules.properties和模块xml,则可以正常工作。我的ModuleConfiguration.java看起来像这样:

package mypackage;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.integration.channel.DirectChannel;
import org.springframework.integration.config.EnableIntegration;
import org.springframework.messaging.MessageChannel;

@Configuration
@EnableIntegration
public class ModuleConfiguration {
    @Bean
    MessageChannel input() {
        return new DirectChannel();
    }
    @Bean
    MessageChannel output() {
        return new DirectChannel();
    }

    @Bean
    MyTransformer transformer() {
        return new MyTransformer();
    }
}


我的pom.xml继承自spring模块pom:

<parent>
   <groupId>org.springframework.xd</groupId>
   <artifactId>spring-xd-module-parent</artifactId>
   <version>1.3.0.RELEASE</version>
   <relativePath/>
</parent>


变形金刚看起来像这样:

package mypackage;

import org.springframework.integration.annotation.MessageEndpoint;
import org.springframework.integration.annotation.Transformer;

@MessageEndpoint
public class MyTransformer
{

   @Transformer( inputChannel = "input", outputChannel = "output" )
   public String transform( String payload )
   {
     return "Test";
   }
}

最佳答案

在您的src/main/resources/config/spring-modules.properties中添加以下内容。

base_packages=mypackage


这将使Spring的XD引擎能够拾取ModuleConfiguration,并依次加载自定义的Transformer MyTransformer

其他一切看起来都不错。

07-24 09:37
查看更多