[jira] [Commented] (AMQ-9101) Queue is Stale - The connection to 'tcp://xxx' is taking a long time to shutdown

[" Gianandrea Rigoni (Jira)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/AMQ-9101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17650096#comment-17650096 ] 

 Gianandrea Rigoni commented on AMQ-9101:
-----------------------------------------

added latest version 5.17.3, since it happens also with this one


> Queue is Stale - The connection to 'tcp://xxx' is taking a long time to shutdown
> --------------------------------------------------------------------------------
>
>                 Key: AMQ-9101
>                 URL: https://issues.apache.org/jira/browse/AMQ-9101
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Transport
>    Affects Versions: 5.16.4, 5.17.1, 5.17.3
>            Reporter:  Gianandrea Rigoni
>            Assignee: Jean-Baptiste Onofré
>            Priority: Major
>             Fix For: 5.18.0, 5.17.4
>
>
> specific queue in Activemq is frozen and messages don't get processed
> multiple ip addresses keep looping in TransportConnection.java
> only stopping and starting solves
> it looks like the loop never ends despite the ip address is not showing in any Hawtio connections 
> I understand that the client might be a slow consumer but the queue should not be frozen/blocked forever
> the problem has been reproduced multiple times under load but also during (apparently) light traffic
> we tried also to shutdown the client apps without any luck, the connection is not existing but the queue does not reset nor returns to and healthy state
> {code:java}
>     @Override
>     public void stop() throws Exception {
>         // do not stop task the task runner factories (taskRunnerFactory, stopTaskRunnerFactory)
>         // as their lifecycle is handled elsewhere
>         stopAsync();
>         while (!stopped.await(5, TimeUnit.SECONDS)) {
>             LOG.info("The connection to '{}' is taking a long time to shutdown.", transport.getRemoteAddress());
>         }
>     }
> {code}
> any suggestions?
> best regards



--
This message was sent by Atlassian Jira
(v8.20.10#820010)