Announcement Announcement Module
Collapse
No announcement yet.
Unscheduled/unnecessary file poll when taskExecutor is not default taskScheduler Page Title Module
Move Remove Collapse
X
Conversation Detail Module
Collapse
  • Filter
  • Time
  • Show
Clear All
new posts

  • 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>
    Last edited by jingyangpeng; Nov 4th, 2011, 03:17 PM.
Working...
X