activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From errobin <>
Subject Consumer hanging after a producer fails for being inactive
Date Sun, 11 Jan 2015 19:21:33 GMT
We are testing ActiveMQ 5.9 with Oracle JDK 1.7.

We created a embedded broker with persistent set to false with a single
We gave it two transportConnectors
 openwire with a
 vm with a uri="vm://localhost"

We have a producer sending messages (50 messages per second) to the queue
using the openwire transport over a vpn connection.
The producer is using the following

We have a single consumer using the vm transport with a MessageListener that
just logs that we received a message.
The consumer is using the following url=vm://localhost

We then have a script that cycles the vpn connection by having the vpn up
for a minute then down for a minute

After about 10-15 minutes we will see in the broker logs

Transport - Transport Connection to: tcp:// failed:
org.apache.activemq.transport.InactivityIOException: Channel was inactive
for too (>30000) long: tcp://

Once we see that error in the logs the consumer stops receiving messages and
the queue starts to grow when the producer reconnects and starts sending
data again.

The consumer code has a Catch Throwable around all the code to try to catch
any exceptions. I have also removed my own simple message consumer and tried
a Camel JMS Consumer and it hangs the same as my message consumer.

I am using JConsole to watch the queue grow and see the consumer count are
at 1 and producer count changes from 0 to 1 depending on if the vpn is up or

So is there anything else I can look at to see why the consumer is not
receiving messages?


View this message in context:
Sent from the ActiveMQ - User mailing list archive at

View raw message