从xml到Java的Spring集成InboundChannelAdapter导致新的轮询控制台日志

Question

将Spring集成bean从xml转换为Java。现在，我得到了每个@InboundChannelAdapter的新控制台日志，这是我以前没有得到的：

AbstractPollingEndpoint task-scheduler-7调试在轮询期间没有收到任何消息，返回“false”

<file:inbound-channel-adapter id="the-file-input"
    directory="file:${import.file.dir.incomingFileDir}" channel="the-input" filter="customFilter" />
<si:channel id="the-input" />
<si:service-activator input-channel="the-input"
    output-channel="job-requests" ref="theJobLauncher" />

<bean id="theJobLauncher" class="com.example.POJO">

</bean>

新的Java配置：

@Bean(name="theInput")
public MessageChannel manifestInputChannel() {
    return new DirectChannel();
}

@Bean(name="theFileInput")
@InboundChannelAdapter(channel="theInput")
public MessageSource<File> filesInboundChannelAdapter(@Value("${import.file.dir.incomingFileDir}") String incomingDirectory){
    FileReadingMessageSource sourceReader = new FileReadingMessageSource();
    sourceReader.setDirectory(new File(incomingDirectory));
    sourceReader.setFilter(customFileFilter);

    sourceReader.afterPropertiesSet();

    return sourceReader;
}


@Bean
@ServiceActivator(inputChannel="theInput", outputChannel="jobRequestsChannel")
public Pojo theJobLauncher() {
    Pojo theJobLauncher = new Pojo();

    return theJobLauncher;
}

Jobjaucher引用具有@MessageEndpoint注释和@ServiceActivator方法的类

这个新的控制台日志行是正常的还是我的配置有问题？

Answer 1

您引用的内容正好在AbstractPollingEndpoint中：

    if (message == null) {
        if (this.logger.isDebugEnabled()) {
            this.logger.debug("Received no Message during the poll, returning 'false'");
        }
        result = false;
    }

因此，这肯定意味着您已经将org.springframework.integration类别的记录器配置为debug级别。

这一点也不疼。您只是在以前的版本中没有这种日志配置。

您不需要自己调用SourceReader.AfterPropertiesSet（）；。这是一个应用程序上下文回调，它确实要被调用，因为您将它声明为bean。

您的@serviceactivator定义不正确。只有当您使用MessageHandler实现时，@bean注释才可以存在。

您可以将@serviceactivator(inputchannel=“theinput”,outputchannel=“jobrequestschannel”）移动到pojo方法中，只需使用@bean为该pojo声明一个bean。或者，由于您已经在该类上使用了@messageendpoint，您可以考虑打开@componentscan来让应用程序上下文获取您的类a bean。

另一种方法实际上类似于MessageHandler实现，并调用您的POJO:

@Bean
@ServiceActivator(inputChannel="theInput", outputChannel="jobRequestsChannel")
public MessageHandler theJobLauncherServiceActivator(Pojo theJobLauncher) {
    return new MethodInvokingMessageHandler(theJobLauncher, (String) null);
}