Mailing-List: contact users-help@camel.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@camel.apache.org
Received-SPF: softfail (athena.apache.org: transitioning domain of
 ai.desu@gmail.com does not designate 216.139.236.26 as permitted sender)
Date: Fri, 20 Sep 2013 04:55:53 -0700 (PDT)
From: Aida <ai.desu@gmail.com>
To: users@camel.apache.org
Message-ID: <1379678153211-5739870.post@n5.nabble.com>
Subject: [ConsumerTemplate] CamelLocks deleted before file is completely
 processed
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: quoted-printable

Hi,

I'm using the consumer template for reading files, and I'm experiencing
something that makes me think that I'm not using it correctly. What happens
to me is:

1. I have a dir with multiple files
2. The consumer template reads one of those files, creating a camelLock fil=
e
for the file that is going to be processed
3. The consumer template reads another file (same route, different thread)
and, since the camelLock of the previous file still exists, deletes it and
creates the camelLock for the file that is going to be processed now (the
previous file haven=C2=B4t ended its processing and haven=C2=B4t been "fini=
shed" using
the doneUnitOfWork)
4. The same for each file that is read (the camelLocks are removed and a
WARNING appears in the log " Deleting orphaned lock file: .../..
.camelLock")

I think that maybe this is because I'm creating a new consumerTemplate each
time I have to read something (could it be?), because I have seen that it
has a ConsumerCache.

The problem is that I use some "rules" to use it (one of them creating the
CT each time), because of some problems I have had in the past:

- Don=C2=B4t use the disconnect option for FTPs (Nullpointer, at least in C=
amel
2.9.0 that leaves threads alive, Camel post in [1])
- Create a new Consumer template each time I read a file (same reasons as
previous sentence) and stop it after use
- I synchronize the method that consumes an endpoint because otherwise, whe=
n
reading files in parallel instead of reading two files, the consumer reads
one twice


In case it can helps, I put my code here:

    =09ConsumerTemplate cTemplate =3D camelContext.createConsumerTemplate()=
;
    =09Exchange dataExchange =3D null;
    =09if(timeoutInMilis =3D=3D 0){
    =09=09dataExchange =3D cTemplate.receiveNoWait(endpoint2Consume);
    =09}
    =09else{
    =09=09dataExchange =3D cTemplate.receive(endpoint2Consume, timeoutInMil=
is);
    =09}    =09
        try {
=09=09=09cTemplate.stop();
=09=09} catch (Exception e) {
=09=09=09log ...
=09=09}

=09=09
Thanks in advance=09=09
=09=09
Camel Version: 2.10.4=09=09
[1]
http://camel.465427.n5.nabble.com/FTP-ConsumerTemplate-Threads-remaining-al=
ive-td5548338.html#a5723551


--
View this message in context: http://camel.465427.n5.nabble.com/ConsumerTem=
plate-CamelLocks-deleted-before-file-is-completely-processed-tp5739870.html
Sent from the Camel - Users mailing list archive at Nabble.com.