We are testing ActiveMQ 5.9 with Oracle JDK 1.7. We created a embedded broker with persistent set to false with a single queue. We gave it two transportConnectors openwire with a uri="tcp://0.0.0.0:61616?maximumConnections=1000&wireFormat.maxFrameSize=104857600" 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 url=failover:(tcp://192.168.100.63:61616)?jms.alwaysSyncSend=true 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://192.168.100.22:36705 failed: org.apache.activemq.transport.InactivityIOException: Channel was inactive for too (>30000) long: tcp://192.168.100.22:36705 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 not. So is there anything else I can look at to see why the consumer is not receiving messages? Thanks, Eric -- View this message in context: http://activemq.2283324.n4.nabble.com/Consumer-hanging-after-a-producer-fails-for-being-inactive-tp4689775.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
