使用 Spring 集成将文件复制到另一个目录引发异常的基本示例

Question

我是 Spring 集成的初学者。我在 spring 引导中编写了这段代码，它引发了异常 "Bean named 'messageSource' is expected to be of type 'org.springframework.context.MessageSource' but was actually of type 'org.springframework.integration.file.FileReadingMessageSource'"

代码：

@Configuration
/*@EnableIntegration annotation designates this class as a Spring Integration configuration.*/
@EnableIntegration
public class SIConfig {

    @Bean
    public MessageChannel channel() {
        return new DirectChannel();
    }
    //bydefault name of method
    @Bean
    public MessageSource messageSource() {
        FileReadingMessageSource ms= new FileReadingMessageSource();
        ms.setDirectory(new File("C:\Users\payal\Pictures"));
        ms.setFilter(new SimplePatternFileListFilter("*.mp4"));
        return ms;
    }

    @Bean
    public MessageHandler handler() {
        FileWritingMessageHandler handler= new FileWritingMessageHandler(new File("C:\Users\payal\Documents\batch7"));
        handler.setFileExistsMode(FileExistsMode.IGNORE);
        handler.setExpectReply(false);
        return handler;

    }

    @Bean
    public IntegrationFlow flow() {
        return IntegrationFlows.from(messageSource(),  configurer -> configurer.poller(Pollers.fixedDelay(10000)))
                .channel(channel())
                .handle(handler()).get();
    }

}

自从使用boot后，版本自动管理

也上传了代码 n GitHub：

https://github.com/LearningNewTechnology/SpringIntegrationOne

任何帮助将不胜感激。

Answer 1

将 bean 的名称更改为，例如

@Bean
public MessageSource myMessageSource() {

Spring 框架（上下文）有另一种类型的 MessageSource 和 Spring 引导自动配置创建一个名称为 messageSource 的该类型的 bean，因此您的 bean 与那。

使用 Spring 集成将文件复制到另一个目录引发异常的基本示例

Basic Example using Spring Integration to copy file to another directory raising exception

spring-integration

spring-integration-dsl