Camel File Komponente - Datei überspringen

Question

Ich benutze die Camel File Komponente, um Dateien aus einem Verzeichnis abzurufen. Bevor ich mit einer Datei umgehen kann, müssen einige Bedingungen erfüllt sein, wenn nicht camel sollte die Datei überspringen, ohne sie zu löschen/verschieben und zum nächsten gehen.

Um dies zu tun, ich benutze diese:

public InputStream myMethod(@Body InputStream is, @Headers .....) { 

if(!checkPrerequisites) 
    throw new MyRuntimeException("conditions not satisfied yet"); 

Also ich frage mich, ob es eine andere Möglichkeit ist es, das gewünschte Verhalten zu archivieren.

Answer 1

Sie könnten eine GenericFileFilter implementieren. Erstellen Sie den Filter, etwa so:

public class AnotherFileExistsFilter<T> implements GenericFileFilter<T> { 

    @Override 
    public boolean accept(GenericFile<T> firstFile) { 
     return Files.exists(Paths.get("/some/other/folder/" + firstFile.getFileName())); 
    } 
} 

Fügen Sie es zu Ihrem Endpunkt mit filter=#anotherFileExistsBeanName.

Wenn Sie die Datei weiterhin prüfen möchten, setzen Sie idempotent=false, und ich empfehle, eine Verzögerung (delay=xxx in ms) einzustellen, um den Ordner nicht kontinuierlich abzufragen.

Weitere Details sind auf der Apache Camel File2 page.