Mailing-List: contact users-help@camel.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@camel.apache.org
Received-SPF: pass (athena.apache.org: domain of claus.ibsen@gmail.com
 designates 74.125.82.45 as permitted sender)
DomainKey-Signature: a=rsa-sha1; c=nofws;
        d=gmail.com; s=gamma;
        h=mime-version:in-reply-to:references:from:date:message-id:subject:to
         :content-type:content-transfer-encoding;
        b=K139ApBmdl/pacc3YO1Mo8VxwMpE+eX2I3I1C2+GK7/G/wEGjOU0cTlvc4LpKGR3bk
         ivEmwTSjpEZiQgLrmgg+NgOXmOdLcHLT58Xm2EotKFTh1tPqIMpdZ7zm1W7anq6Ilsnl
         wLEUEawOHuLn/PsMvhEbk4hO8HXeJjqLkQq+U=
MIME-Version: 1.0
In-Reply-To: <28740002.post@talk.nabble.com>
References: <28740002.post@talk.nabble.com>
From: Claus Ibsen <claus.ibsen@gmail.com>
Date: Tue, 1 Jun 2010 15:38:40 +0200
Message-ID: <AANLkTikmcyS9AYSEn97f6PFaFCb_gaaMx9UJLmKSFM-9@mail.gmail.com>
Subject: Re: Route not shutting down on shutdownRoute (1 inflight).
To: users@camel.apache.org
Content-Type: text/plain; charset=ISO-8859-1
Content-Transfer-Encoding: quoted-printable

On Tue, Jun 1, 2010 at 12:29 PM, ankelee <andreasasmuss@gmail.com> wrote:
>
> Hi
>
> Im trying to create a route that connects to an FTP, downloads the files =
and
> then shuts down the route afterwards to be triggered again later.
>
> I thought I had solved it but I keep getting a "Waiting as there are stil=
l 1
> inflight and pending exchanges to complete before we can shutdown" messag=
e
> until timeout. Which exchange could that be, and can I somehow see it?
>

I have had the though of adding detailed insight to this in the
future. Eg from JMX and also in the logs, where you can configure how
verbose it should be.
For example Camel could detect when an Exchange seems to be stuck and
start logging about it and where it appears to be stuck.

Feel free to create a ticket in JIRA so we wont forget about this.

Also in the future we should have a better DSL for scheduling routes.
For example to tell it to run once or repeat etc. And define period
using CRON or fixed delays etc.
There is already a ticket for this in JIRA.


> All the operations works as intended, except the "FtpPollingRoute" never
> gets shut down until timeout.
>
> <route id=3D"StartFtpTriggerRoute" autoStartup=3D"true">
> =A0 =A0 =A0 =A0<from uri=3D"quartz://scheduledpoll?cron=3D5/30+*+*+*+*+?"=
 />
> =A0 =A0 =A0 =A0<bean ref=3D"ControlFtpPollingRoute" method=3D"start" />
> =A0 =A0 =A0 =A0<stop/>
> </route>
>
> <route id=3D"FtpPollingRoute" autoStartup=3D"false">
> =A0 =A0 =A0 =A0<from
> uri=3D"ftp://{{ftp.server}}{{ftp.inbox}}?username=3D{{ftp.user}}&amp;pass=
word=3D{{ftp.password}}&amp;move=3Ddone"
> />
> =A0 =A0 =A0 =A0<onCompletion>
> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0<log message=3D"onComplete =3D =A0${proper=
ty.CamelBatchComplete}"/>
> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0<filter>
> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0<simple>${property.CamelBa=
tchComplete} =3D=3D true</simple>
> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0<log message=3D"Stopping"/=
>
> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0<bean ref=3D"ControlFtpPol=
lingRoute" method=3D"stop" />
> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0<log message=3D"Stopped"/>
> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0</filter>
> =A0 =A0 =A0 =A0</onCompletion>
> =A0 =A0 =A0 =A0<log message=3D"Fetching ${file:name}"/>
> =A0 =A0 =A0 =A0<to uri=3D"file:{{directory.incoming}}" />
> =A0 =A0 =A0 =A0<log message=3D"${file:name} copied"/>
> </route>
>
>
> [ssword=3Dcamel123&username=3Dcamel] FtpConsumer =A0 =A0 =A0 =A0 =A0 =A0 =
=A0 =A0 =A0 =A0INFO
> Connected and logged in to: ftp://camel@localhost:21
> [ssword=3Dcamel123&username=3Dcamel] FtpPollingRoute =A0 =A0 =A0 =A0 =A0 =
=A0 =A0 =A0INFO
> Fetching =A0CamelinAction (1).pdf
> [ssword=3Dcamel123&username=3Dcamel] FtpPollingRoute =A0 =A0 =A0 =A0 =A0 =
=A0 =A0 =A0INFO
> CamelinAction (1).pdf copied
> [ Camel Thread 1 - OnCompletion] FtpPollingRoute =A0 =A0 =A0 =A0 =A0 =A0 =
=A0 =A0INFO
> onComplete =3D =A0false
> [ssword=3Dcamel123&username=3Dcamel] FtpPollingRoute =A0 =A0 =A0 =A0 =A0 =
=A0 =A0 =A0INFO
> Fetching =A0CamelinAction (2).pdf
> [ssword=3Dcamel123&username=3Dcamel] FtpPollingRoute =A0 =A0 =A0 =A0 =A0 =
=A0 =A0 =A0INFO
> CamelinAction (2).pdf copied
> [ Camel Thread 2 - OnCompletion] FtpPollingRoute =A0 =A0 =A0 =A0 =A0 =A0 =
=A0 =A0INFO
> onComplete =3D =A0false
> [ssword=3Dcamel123&username=3Dcamel] FtpPollingRoute =A0 =A0 =A0 =A0 =A0 =
=A0 =A0 =A0INFO
> Fetching =A0CamelinAction (3).pdf
> [ssword=3Dcamel123&username=3Dcamel] FtpPollingRoute =A0 =A0 =A0 =A0 =A0 =
=A0 =A0 =A0INFO
> CamelinAction (3).pdf copied
> [ Camel Thread 3 - OnCompletion] FtpPollingRoute =A0 =A0 =A0 =A0 =A0 =A0 =
=A0 =A0INFO
> onComplete =3D =A0true
> [ Camel Thread 3 - OnCompletion] FtpPollingRoute =A0 =A0 =A0 =A0 =A0 =A0 =
=A0 =A0INFO
> Stopping
> [ Camel Thread 3 - OnCompletion] DefaultShutdownStrategy =A0 =A0 =A0 =A0I=
NFO
> Starting to graceful shutdown 1 routes (timeout 300 seconds)
> [ Camel Thread 4 - ShutdownTask] DefaultShutdownStrategy =A0 =A0 =A0 =A0I=
NFO =A0Route:
> FtpPollingRoute suspended and shutdown deferred, was consuming from:
> Endpoint[ftp://localhost/inbox?move=3Ddone&password=3Dcamel123&username=
=3Dcamel]
> [ Camel Thread 4 - ShutdownTask] DefaultShutdownStrategy =A0 =A0 =A0 =A0I=
NFO
> Waiting as there are still 2 inflight and pending exchanges to complete
> before we can shutdown
> [ Camel Thread 4 - ShutdownTask] DefaultShutdownStrategy =A0 =A0 =A0 =A0I=
NFO
> Waiting as there are still 1 inflight and pending exchanges to complete
> before we can shutdown
> [ Camel Thread 4 - ShutdownTask] DefaultShutdownStrategy =A0 =A0 =A0 =A0I=
NFO
> Waiting as there are still 1 inflight and pending exchanges to complete
> before we can shutdown
> [ Camel Thread 4 - ShutdownTask] DefaultShutdownStrategy =A0 =A0 =A0 =A0I=
NFO
> Waiting as there are still 1 inflight and pending exchanges to complete
> before we can shutdown
> [ Camel Thread 4 - ShutdownTask] DefaultShutdownStrategy =A0 =A0 =A0 =A0I=
NFO
> Waiting as there are still 1 inflight and pending exchanges to complete
> before we can shutdown
>
> --
> View this message in context: http://old.nabble.com/Route-not-shutting-do=
wn-on-shutdownRoute-%281-inflight%29.-tp28740002p28740002.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>
>


--=20
Claus Ibsen
Apache Camel Committer

Author of Camel in Action: http://www.manning.com/ibsen/
Open Source Integration: http://fusesource.com
Blog: http://davsclaus.blogspot.com/
Twitter: http://twitter.com/davsclaus