Mule File Cấu hình bỏ phiếu trong nước

Question

Tôi muốn thăm dò ý kiến ​​10 tệp tại một thời điểm tại các khoảng thời gian nhất định từ một thư mục cụ thể. Nếu có tồn tại 250 tệp trong thư mục đó, tệp Mule gửi đến phải lấy 10 tệp trong số 250 tệp và xử lý chúng sau đó lại 10 tệp v.v. Tôi có giá trị tham số vòng lặp "10000"

Tôi đã cố gắng áp dụng maxThreadsActive như thế này nhưng nó không làm việc

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

Answer 1

Mule cho phép bạn ghi đè các phần nhất định của việc triển khai phương tiện. Trong trường hợp này, bạn nên ghi đè org.mule.transport.file.FileMessageReceiver, cụ thể là phương thức 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); 
     } 
    } 
} 

Sau đó, tạo một kết nối mà sẽ sử dụng máy thu thông điệp của bạn

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

Cuối cùng, bạn có thể sử dụng kết nối này với bất kỳ thiết bị đầu cuối trong nước tập tin trong cấu hình của bạn. Bạn chỉ cần xác định tần suất bỏ phiếu và bạn đã hoàn tất.

HTH