by Anonymous » 09 Apr 2025, 01:50
Ich habe eine Kamelroute wie unten -
a) Wenn es ein Problem mit dem Lesen von Dateidaten gibt. Wie konfiguriere ich es? Oder kann file-name.err hinzuzufügen und zu processed_Folder zu wechseln. Es sollte sofort den aktuellen und die nachfolgenden Dateien vom Senden
verhindern und im nächsten Cron -Job es versuchen. < /P>
Code: Select all
public void configure() throws IOException {
onException(TooManyLinesException.class, NoLinesException.class)
.handled(true)
.log("File LineLimitErr: ${header.CamelFileName}");
from("file://" + inputFolder + "?includeExt=dat" +
"&eagerMaxMessagesPerPoll=true&maxMessagesPerPoll=100&preSort=true" +
"&move=" + PROCESSED_FOLDER + "/${file:name}" +
"&initialDelay=" + initialDelay + "&scheduler=spring&scheduler.cron=" + cronExpression + "+?")
.log(LoggingLevel.INFO, "Incoming read FileName: ${headers.CamelFileName}")
.log(LoggingLevel.INFO, "File Read: \n ${body}")
.bean(CreateMessageRequest.class) //Error with file lines TooManyLinesException or NoLinesException
.to(SendRequestToAPI.class) // Exceptions with sending to API
.end();
}
Ich habe eine Kamelroute wie unten -
a) Wenn es ein Problem mit dem Lesen von Dateidaten gibt. Wie konfiguriere ich es? Oder kann file-name.err hinzuzufügen und zu processed_Folder zu wechseln. Es sollte sofort den aktuellen und die nachfolgenden Dateien vom Senden [url=viewtopic.php?t=19487]verhindern[/url] und im nächsten Cron -Job es versuchen. < /P>
[code] public void configure() throws IOException {
onException(TooManyLinesException.class, NoLinesException.class)
.handled(true)
.log("File LineLimitErr: ${header.CamelFileName}");
from("file://" + inputFolder + "?includeExt=dat" +
"&eagerMaxMessagesPerPoll=true&maxMessagesPerPoll=100&preSort=true" +
"&move=" + PROCESSED_FOLDER + "/${file:name}" +
"&initialDelay=" + initialDelay + "&scheduler=spring&scheduler.cron=" + cronExpression + "+?")
.log(LoggingLevel.INFO, "Incoming read FileName: ${headers.CamelFileName}")
.log(LoggingLevel.INFO, "File Read: \n ${body}")
.bean(CreateMessageRequest.class) //Error with file lines TooManyLinesException or NoLinesException
.to(SendRequestToAPI.class) // Exceptions with sending to API
.end();
}
[/code]