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/
