activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Keith Irwin" <keith.ir...@gmail.com>
Subject stomp listeners (in python) take down activemq?
Date Wed, 10 May 2006 22:26:59 GMT
Folks--

I've written a little GUI client (in Python) using the stompy2 lib
(referenced on the stomp client page), to "listen" to a bunch of
topics and update the gui.  The idea is to watch specific messages
flow through the system in a graphical way to wow the management. ;)

The problem is that activemq (RC2) throws the following exception (see
post signature) seemingly at random.  Once it gets thrown, one or more
of the java clients I have stops getting messages.  If I kill the
component and restart, messages again flow.  Or I can restart
activemq, and messages once again flow.

Is there something a bit screwy using the stomp protocol?  I use the
"subscribe" part to listen to topics, but don't want durable
subscriptions or anything fancy.

Any clues?

Keith

----

Exception in thread "ActiveMQ Task" java.lang.NullPointerException
        at org.apache.activemq.transport.stomp.Subscription.receive(Subscription.java:79)
        at org.apache.activemq.transport.stomp.StompWireFormat.writeCommand(StompWireFormat.java:144)
        at org.apache.activemq.transport.stomp.StompWireFormat.marshal(StompWireFormat.java:295)
        at org.apache.activemq.transport.tcp.TcpTransport.oneway(TcpTransport.java:120)
        at org.apache.activemq.transport.InactivityMonitor.oneway(InactivityMonitor.java:141)
        at org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:44)
        at org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:55)
        at org.apache.activemq.broker.TransportConnection.dispatch(TransportConnection.java:211)
        at org.apache.activemq.broker.AbstractConnection.processDispatch(AbstractConnection.java:568)
        at org.apache.activemq.broker.AbstractConnection.iterate(AbstractConnection.java:584)
        at org.apache.activemq.thread.SimpleTaskRunner.runTask(SimpleTaskRunner.java:110)
        at org.apache.activemq.thread.SimpleTaskRunner.access$100(SimpleTaskRunner.java:25)
        at org.apache.activemq.thread.SimpleTaskRunner$1.run(SimpleTaskRunner.java:43)
        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)
        at java.lang.Thread.run(Thread.java:595)
E

Mime
View raw message