question on AMQ-1189 and TransportConnection / ActiveMQConnectionConsumer

I've just patched the code to avoid the exception noted here
https://issues.apache.org/activemq/browse/AMQ-1189

I was just wondering what that code was meant to be doing - testing
the consumer being Runnable. ActiveMQConnectionConsumer doesn't
implement Runnable but it does implement ActiveMQDispatcher - I
wondered if the code should check for that interface too? What
consumers might implement Runnable? Anyone who tinkered with this bit
of code in org.apache.activemq.broker.TransportConnection.processDispatch()
know?

--

James
-------
http://radio.weblogs.com/0112098/