using 4.1.1 with client that is consuming messages from a topic using
onMessage for system that passes 400 - 600K messages per day.
Problem - in some but not all clients to the topic, at unpredictable
intervals , we see errors ( below stack trace ) that look like the work of
the "InactivityMonitor" class.
FAQ - in the message passing model where connections are async and the
standard JMS messageListener is in use, is this an accurate description of
threads in use?
onMessage() uses a thread
every time ActiveMQConnection dispatches work or command to the onMsg
thread, 2 other threads run , implementing "readChecker" and "writeChecker"
actions for an instance of "InactivityMonitor" class.
the "readCheck" from its thread may throw an "InactivityIOException" that
can delegate to the listener on the transport.
in such an event, in the other thread, the class implementing "onMessage"
will have its "onException" invoked
---- my stack trace from the message consumer client using "onMessage"
javax.jms.JMSException: Channel was inactive for too long.
Exception in thread "AcitveMQ Connection Worker:
tcp://amq1.realtimematrix.net/192.168.55.5:61616"
java.lang.NullPointerException
| at
com.rtm.Main.CacheAMQConsumer.onException(CacheAMQConsumer.java:172)
| at
org.apache.activemq.ActiveMQConnection$4.run(ActiveMQConnection.java:1524)
<-- rcr this looks to be ASYNC Exception
| at
edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:650)
at
edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:675)
| 2007/10/16 11:05:15 | at java.lang.Thread.run(Thread.java:595)
--
View this message in context:
http://www.nabble.com/listener-%22onMessage%22---Inactive-Channel-excp-tf4637688s2354.html#a13245323
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
