[
https://issues.apache.org/jira/browse/CAMEL-12103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16304399#comment-16304399
]
Yih Tsern commented on CAMEL-12103:
-----------------------------------
I just [read|http://camel.apache.org/support.html] that I'm not supposed to
create a JIRA ticket directly.
Sorry for the faux pas. :/
> Camel unable to shutdown gracefully because Netty4 consumer keep receiving
> and adding inflight exchanges
> --------------------------------------------------------------------------------------------------------
>
> Key: CAMEL-12103
> URL: https://issues.apache.org/jira/browse/CAMEL-12103
> Project: Camel
> Issue Type: Bug
> Components: camel-netty4
> Affects Versions: 2.15.2
> Reporter: Yih Tsern
> Attachments: tcp-client.groovy, tcp-server.camel
>
>
> I'm using this URI: {{netty4:tcp://localhost:8888?sync=false&textline=true}}
> And I have this issue when initiating Camel shutdown using
> {{DefaultShutdownStrategy}}:
> # Camel suspends {{NettyConsumer}}
> ({{SingleTCPNettyServerBootstrapFactory}}), which only stops the "main" Netty
> channel, but _not_ the other Netty channels (i.e. socket connections)
> # Camel waits for routes to be empty of inflight & pending exchanges
> # (!) Those other Netty channels kept receiving data, which are turned into
> new exchanges
> ** As long as the TCP clients keep sending data into the channels + exchanges
> completing slower than send rate, routes will _never_ be empty of inflight &
> pending exchanges
> # Forced shutdown after 5 minutes (timed out)
> h2. To simulate the issue
> # Run the attached [^tcp-server.camel] Groovy script: {{groovy
> tcp-server.camel}}
> # After that has started, run the attached [^tcp-client.groovy]: {{groovy
> tcp-client.groovy}}
> # After tcp-client starts sending data over, stop the tcp-server (CTRL+C in
> Windows)
> # You should see something like this:
> {panel:title=cmd}
> INFO - Apache Camel 2.15.2 (CamelContext: camel-1) started in 1.015 seconds
> INFO - Hey 0
> INFO - Hey 1
> INFO - Hey 2
> INFO - Hey 3
> INFO - Apache Camel 2.15.2 (CamelContext: camel-1) is shutting down
> INFO - Starting to graceful shutdown 1 routes (timeout 300 seconds)
> INFO - Waiting as there are still 1 inflight and pending exchanges to
> complete,
> timeout in 300 seconds.
> INFO - Hey 4
> INFO - Waiting as there are still 1 inflight and pending exchanges to
> complete,
> timeout in 299 seconds.
> INFO - Waiting as there are still 1 inflight and pending exchanges to
> complete,
> timeout in 298 seconds.
> INFO - Hey 5
> INFO - Waiting as there are still 1 inflight and pending exchanges to
> complete,
> timeout in 297 seconds.
> INFO - Waiting as there are still 1 inflight and pending exchanges to
> complete,
> timeout in 296 seconds.
> INFO - Hey 6
> INFO - Waiting as there are still 1 inflight and pending exchanges to
> complete,
> timeout in 295 seconds.
> INFO - Waiting as there are still 1 inflight and pending exchanges to
> complete,
> timeout in 294 seconds.
> ...
> {panel}
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
