Spring Boot Quartz,Integration Inbound channel适配器和触发器绑定

Question

我们有使用XML配置的Quartz Job+File Integration adapter，并且工作得很好，但是，由于尝试将这些配置转移到Spring Boot，并将这些配置转移到注释

下面是XML配置，我正在为它寻找等效的注释和绑定

<bean id="scheduler" 
        class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
        <property name="schedulerContextAsMap">
            <map>
                <entry key="inboundadapterendpoint"><ref bean="incomingfiles" /></entry>
                <entry key="inboundendpointtrigger"><ref bean="incomingfiles-trigger"/></entry>
            </map>
        </property>
</bean>

<bean id="inboundendpointtrigger" class="abc.xyz.Trigger" />

<file:inbound-channel-adapter id="incomingfiles" channel="xyz" directory=""  scanner="recursiveScanner" auto-startup="false" prevent-duplicates="false">
    <integration:poller task-executor="fileChannelTaskExecutor" trigger="incomingfiles-trigger" max-messages-per-poll="1">
    </integration:poller>
</file:inbound-channel-adapter>

我们如何获得入站适配器Bean&使用下面的注释创建的轮询器触发器是在spring Boot quartz config中的调度器工厂创建过程中注入的

@Bean
@InboundChannelAdapter(poller = @Poller(trigger="customTrigger")
public MessageSource<File> fileReadingMessageSource() {

}

提前感谢您对此提供的任何帮助或建议

Artem Bilan非常感谢你的回复。

跟进问题后试用答复中提供的代码

@Configuration
public class QuartzConfig {

    @Autowired
    private CustomTrigger inboundEndPointTrigger;

    @Autowired
    private AbstractEndpoint incomingFiles;


    @Bean
    public SchedulerFactoryBean schedulerFactoryBean() {

    System.out.println("incomingFiles value is  " + incomingFiles);

    }   
}



@Bean(name = "incomingFiles")
@InboundChannelAdapter(autoStartup = "false", value = "xyz", poller = @Poller(trigger = "inboundEndPointTrigger", maxMessagesPerPoll = "2", errorChannel = "abc"))
public MessageSource<File> fileReadingMessageSource() {

}

上面的输出是errorLogger的参考，而不是入站通道适配器。

incomingFiles值为bean“_org.springframework.integration.errorlogger”

如何将名为incomingFiles的入站适配器绑定到调度程序工厂？

  @Bean
  @EndPointId("incomingFiles")
    @InboundChannelAdapter(autoStartup = "false", value = "xyz", poller = @Poller(trigger = "inboundEndPointTrigger", maxMessagesPerPoll = "2", errorChannel = "abc"))
    public MessageSource<File> fileReadingMessageSource() {

    }

System.out.println("incomingFiles value is  " + incomingFiles);  print in  QuartzConfig class above is still giving a reference to  Logger object 

incomingFiles value is  bean '_org.springframework.integration.errorLogger'

在下面的SO（Spring Cloud Stream+Quartz)中找到了关于如何为入站通道适配器创建bean的响应。

Since the AbstractEndPoint is returning the logger reference instead of InboundChannelAdapter , 
is it ok to  get the Inbound Adapter channel bean reference via application context  in scheduler factory ? are there any issues with this ?

try {
    ApplicationContext applicationContext = (ApplicationContext) context.getScheduler().getContext().get("applicationContext");
    AbstractEndpoint abstractEndPoint = (AbstractEndpoint) applicationContext
                    .getBean("fileConfig.fileReadingMessageSource.inboundChannelAdapter");
} catch(SchedulerException ex) {
}


fileConfig is the Spring File integration configuration class name where InboundChannelAdapter is defined.. 

Answer 1

我不知道为什么你关闭了你的旧问题-你可以只是编辑它适当，我们将有一个链接到其他问题。但不管怎样，答案是这样的：

任何XML bean定义都可以用@bean方法定义在Java&annotation config中声明。

因此， 在Java中的格式如下：

@Bean
Trigger customTrigger() {
   return new abc.xyz.Trigger();
}

您已经在@poller中使用它的bean名称作为引用。

对SchedulerFactoryBean也是这样做的，并在@bean方法中配置它的setSchedulerContextAsMap（）。您已经有一个customTrigger()bean可供参考，并且可以基于@InboundChannelAdapter访问SourcePollingChannelAdapterendpoint，您需要注入@bean方法。差不多是这样的：

 @Bean
 SchedulerFactoryBean schedulerFactory(Trigger trigger, SourcePollingChannelAdapter endpoint) {

 }

不要忘记使用@InboundChannelAdapter(autoStartup=“false”），正如Gary在其他SO问题中所建议那样。