Re: uses virtual topic and ClientAcknowledge to submit themessage occured probem

> 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
> >