activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Keith Irwin" <keith.ir...@gmail.com>
Subject Re: stomp listeners (in python) take down activemq?
Date Fri, 12 May 2006 01:18:41 GMT
On 5/11/06, Hiram Chirino <hiram@hiramchirino.com> wrote:
> The stomp protocol had some small issues recently fixed.  I would try
> against new binary like the the latest 4.0 release candidate at:

Hiram--

Thanks!  I was finally able to download the latest snapshot and sure
enough, things seem to work as I expect them to. ;)

Regards,

Keith

>
> http://people.apache.org/~chirino/incubator-activemq-4.0/maven1/incubator-activemq/distributions/
>
>
> On 5/10/06, Keith Irwin <keith.irwin@gmail.com> wrote:
> > 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
> >
>
>
> --
> Regards,
> Hiram
>

Mime
View raw message