1 Attachment(s)
Unscheduled/unnecessary file poll when taskExecutor is not default taskScheduler
After one poll and process(hadler.handleFile sleep 5s then do real process), there are bunch of unscheduled polls although i set 1s delay . Is it an issue? log is attached.
Context:
Code:
<integration:channel id="filesIn-1"/>
<integration:inbound-channel-adapter id="inbound-channel-adapter-1" ref="pollableFileSource-1" channel="filesIn-1" >
<integration:poller ref="filePoller-1" />
</integration:inbound-channel-adapter>
<file:outbound-channel-adapter id="filesOut-1"
delete-source-files="true" filename-generator="fileNameGenerator"
directory="${dealer_dir}">
</file:outbound-channel-adapter>
<integration:service-activator
input-channel="filesIn-1" output-channel="filesOut-1" ref="handler" method="handleFile">
</integration:service-activator>
<integration:poller id="filePoller-1"
max-messages-per-poll="2" default="false"
trigger="fixedDelayTrigger-1" task-executor="taskExecutor-1">
<integration:transactional transaction-manager="transactionManager"/>
</integration:poller>
<bean id="fixedDelayTrigger-1" class="org.springframework.scheduling.support.PeriodicTrigger"
p:fixedRate="false">
<constructor-arg value="1000"/>
</bean>
<bean id="taskExecutor-1"
class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor"
p:threadNamePrefix="orderTask-1_"
p:waitForTasksToCompleteOnShutdown="true"
p:maxPoolSize="1"
>
</bean>
<bean id="pollableFileSource-1"
class="org.springframework.integration.file.FileReadingMessageSource"
p:directory="${dealer_dir}"
p:scanner-ref="directoryFilterScanner-1"
>
<constructor-arg ref="lastModifiedFileComparator"/>
</bean>
<bean id="directoryFilterScanner-1" class="c.f.fileprocess.DirectoryFilterScanner"
p:dirFilter="g#{fileProcessDefinition.groupCodeParttern('1')}${environment}[0-9]{2}/in/OS">
<property name="filter">
<bean class="org.springframework.integration.file.filters.AcceptAllFileListFilter"/>
</property>
</bean>