activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Hiram Chirino" <hi...@hiramchirino.com>
Subject Re: stomp listeners (in python) take down activemq?
Date Fri, 12 May 2006 05:48:07 GMT
Excellent!

On 5/11/06, Keith Irwin <keith.irwin@gmail.com> wrote:
> 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
> >
>


-- 
Regards,
Hiram

Mime
View raw message