Konfiguracja odpytywania przychodzących plików Mule

Question

Chcę odpytywać 10 plików jednocześnie w określonych odstępach czasu od określonego katalogu. Jeśli istnieje 250 plików w tym folderze, przychodzące pliki Mule powinny zająć 10 plików na 250 i przetworzyć je ponownie 10 plików itp. Mam wartość częstotliwości odpytywania "10000"

Próbowałem zastosować maxThreadsActive w ten sposób, ale nie robi praca

<file:connector> 
<receiver-thread-profile maxThreadsActive=10/> 
</file:connector> 

Answer 1

Mule pozwala unieważnić niektóre elementy realizacji transportu. W takim przypadku należy zastąpić metodę org.mule.transport.file.FileMessageReceiver, konkretnie listFiles().

public class MyFileMessageReceiver extends FileMessageReceiver 
{ 
    private static final MAX_FILES = 10; 

    @Override 
    List<File> listFiles() throws MuleException 
    { 
     try 
     { 
      List<File> files = new ArrayList<File>(); 
      this.basicListFiles(readDirectory, files); 

      if(files.isEmpty()) 
       return NO_FILES; 

      if(files.size() > MAX_FILES) 
       return files.subList(0, MAX_FILES); 
      else 
       return files; 
     } 
     catch (Exception e) 
     { 
      throw new DefaultMuleException(FileMessages.errorWhileListingFiles(), e); 
     } 
    } 
} 

Następnie należy utworzyć łącznik, który będzie używany odbiornik wiadomość

<file:connector name="inboundFileConnector"> 
    <service-overrides messageReceiver="org.mule.transport.file.MyFileMessageReceiver"/> 
</file:connector> 

Wreszcie można użyć tego złącza z dowolnego punktu końcowego przychodzących plików w swojej konfiguracji. Musisz tylko określić częstotliwość odpytywania i gotowe.

HTH