You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by magellings <ma...@qg.com> on 2009/06/29 19:12:58 UTC
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.
Re: uses virtual topic and ClientAcknowledge to submit
themessageoccured probem
Posted by magellings <ma...@qg.com>.
I tested on the latest 5.3 snapshot (-5.3-20090620.174423-1-bin) and the same
exception occurs. I don't know if this is related to NMS or not. Maybe you
could try to replicate it? Can you run your unit test and look at the
broker log to see if the error is logged?
magellings wrote:
>
> I can give 5.3 a shot.
>
> But there is an issue created for 5.4 right now.
>
> https://issues.apache.org/activemq/browse/AMQ-1763
>
> This is why I was wondering if it is related to NMS or the broker. The
> original poster mentions VT work fine with java code.
>
> I'm currently using 5.2 and 1.1 of NMS.
>
>
>
>
> semog wrote:
>>
>> Thanks for the offer of help. I am not sure where the problem is. I have
>> seen broker problems with virtual topics if queue mirroring is turned on,
>> so it is possible the error is in the broker. It would be good to test
>> against the latest ActiveMQ 5.3 snapshot.
>>
>> - Jim
>>
>> -----Original Message-----
>> From: magellings <ma...@qg.com>
>>
>> Date: Mon, 29 Jun 2009 11:56:20
>> To: <us...@activemq.apache.org>
>> Subject: 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
>>>
>>> -----Original Message-----
>>> From: magellings <ma...@qg.com>
>>>
>>> Date: Mon, 29 Jun 2009 10:12:58
>>> To: <us...@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.
>>>
>>>
>>>
>>
>> --
>> View this message in context:
>> http://www.nabble.com/uses-virtual-topic---and-ClientAcknowledge-to-submit-the-message-occured-probem-tp22486742p24259354.html
>> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>>
>>
>>
>
>
--
View this message in context: http://www.nabble.com/uses-virtual-topic---and-ClientAcknowledge-to-submit-the-message-occured-probem-tp22486742p24261671.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: uses virtual topic and ClientAcknowledge to submit
themessageoccured probem
Posted by magellings <ma...@qg.com>.
I can give 5.3 a shot.
But there is an issue created for 5.4 right now.
https://issues.apache.org/activemq/browse/AMQ-1763
This is why I was wondering if it is related to NMS or the broker. The
original poster mentions VT work fine with java code.
I'm currently using 5.2 and 1.1 of NMS.
semog wrote:
>
> Thanks for the offer of help. I am not sure where the problem is. I have
> seen broker problems with virtual topics if queue mirroring is turned on,
> so it is possible the error is in the broker. It would be good to test
> against the latest ActiveMQ 5.3 snapshot.
>
> - Jim
>
> -----Original Message-----
> From: magellings <ma...@qg.com>
>
> Date: Mon, 29 Jun 2009 11:56:20
> To: <us...@activemq.apache.org>
> Subject: 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
>>
>> -----Original Message-----
>> From: magellings <ma...@qg.com>
>>
>> Date: Mon, 29 Jun 2009 10:12:58
>> To: <us...@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.
>>
>>
>>
>
> --
> View this message in context:
> http://www.nabble.com/uses-virtual-topic---and-ClientAcknowledge-to-submit-the-message-occured-probem-tp22486742p24259354.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
>
>
--
View this message in context: http://www.nabble.com/uses-virtual-topic---and-ClientAcknowledge-to-submit-the-message-occured-probem-tp22486742p24260431.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: uses virtual topic and ClientAcknowledge to submit themessageoccured probem
Posted by Jim Gomes <e....@gmail.com>.
Thanks for the offer of help. I am not sure where the problem is. I have seen broker problems with virtual topics if queue mirroring is turned on, so it is possible the error is in the broker. It would be good to test against the latest ActiveMQ 5.3 snapshot.
- Jim
-----Original Message-----
From: magellings <ma...@qg.com>
Date: Mon, 29 Jun 2009 11:56:20
To: <us...@activemq.apache.org>
Subject: 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
>
> -----Original Message-----
> From: magellings <ma...@qg.com>
>
> Date: Mon, 29 Jun 2009 10:12:58
> To: <us...@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.
>
>
>
--
View this message in context: http://www.nabble.com/uses-virtual-topic---and-ClientAcknowledge-to-submit-the-message-occured-probem-tp22486742p24259354.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: uses virtual topic and ClientAcknowledge to submit
themessage occured probem
Posted by Timothy Bish <ta...@gmail.com>.
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/
Re: uses virtual topic and ClientAcknowledge to submit themessage
occured probem
Posted by magellings <ma...@qg.com>.
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 <ma...@qg.com>
>
> Date: Mon, 29 Jun 2009 10:12:58
> To: <us...@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.
>
>
>
--
View this message in context: http://www.nabble.com/uses-virtual-topic---and-ClientAcknowledge-to-submit-the-message-occured-probem-tp22486742p24259354.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: uses virtual topic and ClientAcknowledge to submit themessage occured probem
Posted by Jim Gomes <e....@gmail.com>.
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 <ma...@qg.com>
Date: Mon, 29 Jun 2009 10:12:58
To: <us...@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.