Details
Major Description
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
@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());
}
}
any suggestions?
best regards