Hi,
I am using camel 2.6. I have a route which is configured to listen to topic.
When I run the route its starting fine, but it is not consuming the message
from the topic and giving the WARN:
2013-04-18 10:10:45,104|[aultMessageListenerContainer-1]
efaultMessageListenerContainer WARN Setup o
Hi,
I wanted to remove old .camellock files on start up .
I am getting :
WARN |
org.apache.camel.component.file.strategy.FileChangedExclusiveReadLockStrategy |
Cannot acquire read lock within 6 millis. Will skip the file:
messages in the log, as there are old .camellock files on start u
up
Hi
What version of Camel do you use?
And do you have a cluster of Camel running, that compete for the "same" files?
On Wed, Nov 28, 2012 at 4:37 PM, Kesireddy, Chandana (ITD)
wrote:
> Hi,
>
> I wanted to remove old .camellock files on start up .
> I
Hi,
I am writing custom GenericFileProcessStrategy class . Iam not able to create
.camelLock extension on the file when it processes the file.
I want the file to be deleted after it is processed.
Please let me know how to create .camelLock extension on the file using using
custom GenericFileP
ssage-
From: Claus Ibsen [mailto:claus.ib...@gmail.com]
Sent: Thursday, November 29, 2012 7:25 AM
To: users@camel.apache.org
Subject: Re: creating .camelLock extension on file using custom
GenericFileProcessStrategy
On Wed, Nov 28, 2012 at 10:44 PM, Kesireddy, Chandana (ITD)
wrote:
> Hi,
ov 29, 2012 at 4:00 PM, Kesireddy, Chandana (ITD)
wrote:
> Thanks for replying.
> My problem here is , it's not creating .camelLock extension on the file when
> it is processing the file, using custom GenericFileProcessStrategy.
> What do I need to do in order to make it create .
:32 PM, Kesireddy, Chandana (ITD)
wrote:
> Claus,
>
> Thanks for replying.
> So in the begin method , I need write code to create an empty file with
> .camelLock extension and return true.
>
> In commit method I need to write code to delete both the original file and
Following is the route :
public class MyRouteBuilder extends RouteBuilder {
@Override
public void configure() throws Exception {
// xnc route here
String xncFileSupport = ICEndPoints.getValue(XNC_FILE_SUPPORT);
if (XNC_SUPPORT_ON.equalsIgnoreCase(xncFileSupport)) {
try {
InProce
