Questions tagged [camel-file]

12 questions
1
vote
1 answer

restarting a route initialized with File component does not poll the existing files again

Thanks to JMX (java console), I try to restart a route with a file component consumer endpoint. from("file:?noop=true") I am using the wiretap pattern to record the intermediate data transformation through other files endpoint. On first…
izaac
  • 31
  • 4
1
vote
0 answers

Apache Camel File Component: Exception after aggregation should move file to .error folder

My goal is to move a pdf and a xml file from an input to an output folder when both files are available in the input folder. If one file is not available it should retry a couple of times and then move the file to an .error folder. I noticed that…
dev-random
  • 741
  • 1
  • 7
  • 13
1
vote
1 answer

Camel 2.x not recognising 'preSort' File component parameter

We're using Camel's File component to receive files that are placed into a directory. The URI for this is similar…
DuncanKinnear
  • 4,563
  • 2
  • 34
  • 65
1
vote
1 answer

Why does camel move file with only partial data?

Below is my code: from("quartz2:report?cron=" + cronExpression) .routeId("jms:queue:test") .setHeader("CURRENT_TIME", simple("${date:now:MM-dd-yyyy HH:mm:ss.S}")) //Writing column names for report to the file .setBody() …
1
vote
1 answer

Apache camel file component to periodically read files without deleting or moving files and without idempotency

file:/../..?noop=true&scheduler=quartz2&scheduler.cron=0+0/10+*+*+*+? Using noop=true allows me to have the files at same place after the route consumes the files but it also enables idempotent which I don't want. (There is second route which will…
user0904
  • 210
  • 3
  • 7
1
vote
1 answer

Apache Camel as file explorer

I need a way to show the content of a (remote) directory and, since the main application makes an intensive use of Apache Camel, I would like to rely on Apache Camel once more to accomplish this task. So, the goal is to have a file explorer view…
AV FMX
  • 45
  • 1
  • 1
  • 7
1
vote
0 answers

Rolling back individual input files when sending after aggregation fails

I'm currently trying to migrate some legacy code/system to Camel. The current system is working with a lot of folders for queues and processes all messages in a these queues sequentially instead of processing the full flow for a message completely…
Kukeltje
  • 12,223
  • 4
  • 24
  • 47
0
votes
1 answer

Use custom processStrategy with file endpoint

I have created a custom processStrategy that is an extention of the GenericFileDeleteProcessStrategy: @Component public class AlwaysDeleteProcessStrategy extends GenericFileDeleteProcessStrategy { private static final Logger LOGGER =…
MarcoB
  • 49
  • 6
0
votes
0 answers

Enrich and Aggregation taking 2 secs to process the data in Camel

I am trying to fetch the data from the file(size of 70 KB) and aggregate the data at the same time but it is getting delayed by 2 seconds for all the requests to finish the process. Below is the code. Camel context file:
Kiran
  • 13
  • 5
0
votes
1 answer

Camel standalone application - exit after processing multiple files

I have a standalone Camel application that is executed by an external task scheduler. Because of this, it needs to exit once execution is finished. To accomplish this, I'm passing the command line argument -dm 1 to process a single message before…
Makaque
  • 163
  • 2
  • 9
0
votes
1 answer

Setting a custom processStrategy in the Spring Camel file component throws Could not find a suitable setter for property: processStrategy

I'm trying to set a custom processStrategy in Camel 2.23.2. I've tried several ways to reference it from the processStrategy uri parameter, but I always get this exception: Caused by: java.lang.IllegalArgumentException: Could not find a suitable…
codependent
  • 23,193
  • 31
  • 166
  • 308
0
votes
0 answers

Standalone Apache Camel JAR is not able to read file content

I have written a small Camel application (https://github.com/bhushantimilsina/camel-simple-app) that reads file from inbox directory, calls a processor to change its case and write output to a file in outbox directory. When I run the main class…