activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Timothy Bish <tabish...@gmail.com>
Subject Re: uses virtual topic and ClientAcknowledge to submit themessage occured probem
Date Mon, 29 Jun 2009 19:18:09 GMT

Are you using the latest trunk code, or is this a version that you've
had for awhile?  

Regards
Tim.

On Mon, 2009-06-29 at 11:56 -0700, magellings wrote:
> Hey Jim thanks for the response.
> 
> I took a look at your test.
> 
> I too can receive messages just fine with a transactional session.
> 
> The problem is that the message does not get removed from the queue when you
> commit the session.
> 
> Instead the broker writes to the log an error like the following and the
> next time around the consumer gets the same message as redelivered.  I'm
> wondering if this error is due to how NMS connects to the broker or
> something internal to the broker itself.  If it is NMS than I'd be more than
> willing to take a closer look.  Thoughts?
> 
> 2009-06-29 13:50:36,340 [//10.0.1.5:1766] ERROR Service                       
> - Async error occurred: java.lang.IllegalArgumentException: The subscription
> does not exist: a7e81a30-fa47-4d35-b8ca-3641a1457f11:1:1
> java.lang.IllegalArgumentException: The subscription does not exist:
> a7e81a30-fa47-4d35-b8ca-3641a1457f11:1:1
> 	at
> org.apache.activemq.broker.region.AbstractRegion.acknowledge(AbstractRegion.java:364)
> 	at
> org.apache.activemq.broker.region.RegionBroker.acknowledge(RegionBroker.java:462)
> 	at
> org.apache.activemq.broker.TransactionBroker.acknowledge(TransactionBroker.java:194)
> 	at
> org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:74)
> 	at
> org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:74)
> 	at
> org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:74)
> 	at
> org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:74)
> 	at
> org.apache.activemq.broker.MutableBrokerFilter.acknowledge(MutableBrokerFilter.java:85)
> 	at
> org.apache.activemq.broker.TransportConnection.processMessageAck(TransportConnection.java:456)
> 	at org.apache.activemq.command.MessageAck.visit(MessageAck.java:205)
> 	at
> org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:305)
> 	at
> org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:179)
> 	at
> org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:68)
> 	at
> org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:143)
> 	at
> org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:206)
> 	at
> org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:84)
> 	at
> org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:203)
> 	at
> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:185)
> 	at java.lang.Thread.run(Unknown Source)
> 
> 
> semog wrote:
> > 
> > I created some virtual topic tests for NMS awhile ago, and they are all
> > working. You can view the tests in VirtualTopicTest.cs in the
> > Apache.NMS.ActiveMQ project. 
> > 
> > Regarding this particular problem, I would have to do further
> > investigation to find the ultimate source of the problem. 
> > 
> > - Jim
> > 

-- 
Tim Bish
http://fusesource.com
http://timbish.blogspot.com/




Mime
View raw message