camel routes suspend /resume

classic Classic list List threaded Threaded
4 messages Options
Reply | Threaded
Open this post in threaded view
|

camel routes suspend /resume

kiranreddykasa
Hi
 
Netty is still accepting new connections and new message even though it is suspended.

I'm able to suspend and resume routes by jmx via jconsole.
When I'm suspending second route it's working correctly, i.e it stopped processing messages.
Where as if I'm suspending first route netty is still accepting new connections/messages.

When ever I'm suspending it's logging that it's suspended.
Here is my configuration.

      <camelContext xmlns="http://camel.apache.org/schema/spring">
                <route>
                        <from uri="netty:tcp://0.0.0.0:7005?textline=true" />
                        <to uri="activemq:QUEUE2" />
                </route>
                <route>
                        <from uri="activemq:QUEUE2" />
                        <bean ref="testProcessor" />
                </route>
        </camelContext>

camel version : 2.11.1
Regards

kiran Reddy
Reply | Threaded
Open this post in threaded view
|

Re: camel routes suspend /resume

Claus Ibsen-2
Use stop/start for the netty route

On Fri, Aug 16, 2013 at 10:24 AM, kiranreddykasa <[hidden email]> wrote:

> Hi
>
> Netty is still accepting new connections and new message even though it is
> suspended.
>
> I'm able to suspend and resume routes by jmx via jconsole.
> When I'm suspending second route it's working correctly, i.e it stopped
> processing messages.
> Where as if I'm suspending first route netty is still accepting new
> connections/messages.
>
> When ever I'm suspending it's logging that it's suspended.
> Here is my configuration.
>
>       <camelContext xmlns="http://camel.apache.org/schema/spring">
>                 <route>
>                         <from uri="netty:tcp://0.0.0.0:7005?textline=true" />
>                         <to uri="activemq:QUEUE2" />
>                 </route>
>                 <route>
>                         <from uri="activemq:QUEUE2" />
>                         <bean ref="testProcessor" />
>                 </route>
>         </camelContext>
>
> camel version : 2.11.1
>
>
>
> -----
> Regards
>
> kiran Reddy
> --
> View this message in context: http://camel.465427.n5.nabble.com/camel-routes-suspend-resume-tp5737382.html
> Sent from the Camel - Users mailing list archive at Nabble.com.



--
Claus Ibsen
-----------------
Red Hat, Inc.
Email: [hidden email]
Twitter: davsclaus
Blog: http://davsclaus.com
Author of Camel in Action: http://www.manning.com/ibsen
Reply | Threaded
Open this post in threaded view
|

Re: camel routes suspend /resume

kiranreddykasa
Hi,

So the following route policy cannot be used?

org.apache.camel.impl.ThrottlingInflightRoutePolicy
Regards

kiran Reddy
Reply | Threaded
Open this post in threaded view
|

Re: camel routes suspend /resume

Claus Ibsen-2
Hi

Yeah we can improve camel-netty to be able to unbind/bind the acceptor
when suspended/resume. I have logged a ticket
https://issues.apache.org/jira/browse/CAMEL-6644

On Fri, Aug 16, 2013 at 2:29 PM, kiranreddykasa <[hidden email]> wrote:

> Hi,
>
> So the following route policy cannot be used?
>
> org.apache.camel.impl.ThrottlingInflightRoutePolicy
>
>
>
> -----
> Regards
>
> kiran Reddy
> --
> View this message in context: http://camel.465427.n5.nabble.com/camel-routes-suspend-resume-tp5737382p5737407.html
> Sent from the Camel - Users mailing list archive at Nabble.com.



--
Claus Ibsen
-----------------
Red Hat, Inc.
Email: [hidden email]
Twitter: davsclaus
Blog: http://davsclaus.com
Author of Camel in Action: http://www.manning.com/ibsen