Mailing-List: contact users-help@camel.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@camel.apache.org
Received-SPF: pass (nike.apache.org: domain of xcoulon@gmail.com designates
 209.85.216.45 as permitted sender)
DomainKey-Signature: a=rsa-sha1; c=nofws;
        d=gmail.com; s=gamma;
        h=mime-version:date:message-id:subject:from:to:content-type;
        b=kqVhH+itpyr80QSTo8NdtixVZM8uYW9Y5BpAaw2amaCfnO7ztR1vkcakB0h9F+CGvi
         5n8esPeL9EjlSfSe56p3r/axupDw7J6J7gvihe+7CtH/srvlfNposlbe9kPNbAa+ZcWe
         66PUZQNZlOMPaXt0+j5HSJzzVG5fB67NOZztY=
MIME-Version: 1.0
Date: Wed, 1 Jun 2011 17:01:47 +0200
Message-ID: <BANLkTim3XMvZ1CQa5B3LPaJ7h3=dZF2d0A@mail.gmail.com>
Subject: Inflight and pending exchange in a route during shutdown
From: Xavier Coulon <xcoulon@gmail.com>
To: users@camel.apache.org
Content-Type: multipart/alternative; boundary=0014853e352eb0a3c604a4a7cccb

--0014853e352eb0a3c604a4a7cccb
Content-Type: text/plain; charset=ISO-8859-1

Hello,

I'm having an issue with the File Component in my test case. Running a test
from within Eclipse works fine, running the exact same test with Maven fails
because of a timeout I set on the test method.

On the Eclipse side, during the route with a file endpoint is shutdown with
the following messages:
ShutdownTask][org.apache.camel.impl.DefaultShutdownStrategy:suspendNow]
Suspending: Consumer[file://D:/tmp/integration]
[16:12:06,735][TRACE][Camel (context1) thread #18 -
ShutdownTask][org.apache.camel.util.ServiceHelper:suspendService] Suspending
service Consumer[file://D:/tmp/integration]
[16:12:06,735][DEBUG][Camel (context1) thread #18 -
ShutdownTask][org.apache.camel.impl.DefaultShutdownStrategy:suspendNow]
Suspend complete for: Consumer[file://D:/tmp/integration]
[16:12:06,735][ INFO][Camel (context1) thread #18 -
ShutdownTask][org.apache.camel.impl.DefaultShutdownStrategy$ShutdownTask:run]
Route: stock.route.phase1.fileValidation suspended and shutdown deferred,
was consuming from: Endpoint[file://D:/tmp/integration]
[16:12:06,735][DEBUG][Camel (context1) thread #18 -
ShutdownTask][org.apache.camel.impl.DefaultShutdownStrategy$ShutdownTask:run]
Route: stock.route.phase1.xml.aggregation preparing to shutdown.
[16:12:06,735][ INFO][Camel (context1) thread #18 -
ShutdownTask][org.apache.camel.impl.DefaultShutdownStrategy$ShutdownTask:run]
Route: stock.route.phase1.xml.aggregation preparing to shutdown complete.
[16:12:06,735][DEBUG][Camel (context1) thread #18 -
ShutdownTask][org.apache.camel.impl.DefaultShutdownStrategy$ShutdownTask:run]
Route: stock.route.phase1.fileSplitting preparing to shutdown.
[16:12:07,157][TRACE][Camel (context1) thread #6 -
file://D:/tmp/integration][org.apache.camel.impl.ScheduledPollConsumer:run]
Cannot start to poll: Endpoint[file://D:/tmp/integration] as its suspended
[16:12:07,251][ INFO][Camel (context1) thread #18 -
ShutdownTask][org.apache.camel.impl.DefaultShutdownStrategy$ShutdownTask:run]
Route: stock.route.phase1.fileSplitting preparing to shutdown complete.
[16:12:07,251][DEBUG][Camel (context1) thread #18 -
ShutdownTask][org.apache.camel.impl.DefaultShutdownStrategy$ShutdownTask:run]
Route: stock.route.phase1.fileValidation preparing to shutdown.
[16:12:07,251][ INFO][Camel (context1) thread #18 -
ShutdownTask][org.apache.camel.impl.DefaultShutdownStrategy$ShutdownTask:run]
Route: stock.route.phase1.fileValidation preparing to shutdown complete.
[16:12:07,251][TRACE][Camel (context1) thread #18

With Maven, I have the following messages:
[16:16:01,670][TRACE][Camel (context1) thread #19 -
ShutdownTask][org.apache.camel.impl.DefaultShutdownStrategy$ShutdownTask:run]
Shutting down route: stock.route.phase1.fileValidation with options
[Default,CompleteCurrentTaskOnly]
[16:16:01,670][TRACE][Camel (context1) thread #19 -
ShutdownTask][org.apache.camel.impl.DefaultShutdownStrategy:suspendNow]
Suspending: Consumer[file://D:/tmp/integration]
[16:16:01,670][TRACE][Camel (context1) thread #19 -
ShutdownTask][org.apache.camel.util.ServiceHelper:suspendService] Suspending
service Consumer[file://D:/tmp/integration]
[16:16:01,670][DEBUG][Camel (context1) thread #19 -
ShutdownTask][org.apache.camel.impl.DefaultShutdownStrategy:suspendNow]
Suspend complete for: Consumer[file://D:/tmp/integration]
[16:16:01,670][ INFO][Camel (context1) thread #19 -
ShutdownTask][org.apache.camel.impl.DefaultShutdownStrategy$ShutdownTask:run]
Route: stock.route.phase1.fileValidation suspended and shutdown deferred,
was consuming from: Endpoint[file://D:/tmp/integration]
[16:16:01,670][DEBUG][Camel (context1) thread #19 -
ShutdownTask][org.apache.camel.impl.DefaultShutdownStrategy$ShutdownTask:run]
1 inflight and pending exchanges for consumer:
Consumer[file://D:/tmp/integration]
[16:16:01,670][ INFO][Camel (context1) thread #19 -
ShutdownTask][org.apache.camel.impl.DefaultShutdownStrategy$ShutdownTask:run]
Waiting as there are still 1 inflight and pending exchanges to complete,
timeout in 300 seconds.

and this lasts for 300s, until the shutdown is forced..

The weird thing is that there should be only one exchange in this route, and
it was processed in other routes after this one...

I don't know if it's related to the way tests are run with Maven, but is
there anything I could add to get rid of the stuck inflight exchange ?

Thank you in advance
Regards,
-- 
Xavier

--0014853e352eb0a3c604a4a7cccb--