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/
