« Return to Thread: uses virtual topic and ClientAcknowledge to submit the message occured probem

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

by magellings :: Rate this Message:

Reply to Author | View in Thread

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

-----Original Message-----
From: magellings <mark.gellings@qg.com>

Date: Mon, 29 Jun 2009 10:12:58
To: <users@activemq.apache.org>
Subject: Re: uses virtual topic   and ClientAcknowledge to submit the
 message occured probem



Is this an NMS specific problem or with the actual broker?

I see the link below but the user is saying everything works with java code.

Does anyone know what version of ActiveMQ Virtual Topics did work?  

http://activemq.apache.org/virtual-destinations.html 


pclovec wrote:
>
> i try to test virtual  topic  found out the isssue
> 1.create cosumer.a.virtualtopic.test queue.
> 2.create cosumer.b.virtualtopic.test queue.
> 3.create  virtualtopic.test queue
> 4.send message into topic
> 5 consumer a and b can got the message ,but i want to try to submit the
> server it occure error
>    ---msga.Acknowledge();
>
> i uses NMS and NMS.ActiveMQ
>
> it's issue?. or just i missing something. but i try to uses java code test
> it . everything is work.
>
> thanks
>
>
>
> 2009-03-12 17:34:06,885 [/127.0.0.1:1366] ERROR Service                      
> - Async error occurred: java.lang.IllegalArgumentException: The
> subscription does not exist: c91df03f-0766-493e-b1db-dacfd9a5e9df:2:1
> java.lang.IllegalArgumentException: The subscription does not exist:
> c91df03f-0766-493e-b1db-dacfd9a5e9df:2: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.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(Thread.java:619)
>
>

--
View this message in context: http://www.nabble.com/uses-virtual-topic---and-ClientAcknowledge-to-submit-the-message-occured-probem-tp22486742p24258128.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

 « Return to Thread: uses virtual topic and ClientAcknowledge to submit the message occured probem