uses virtual topic and ClientAcknowledge to submit the message occured probem
|
View:
New views
9 Messages
—
Rating Filter:
Alert me
|
 |
uses virtual topic and ClientAcknowledge to submit the message occured probem
by pclovec
::
Rate this Message:
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) |
|
|
Re: uses virtual topic and ClientAcknowledge to submit the message occured probem
by pclovec
::
Rate this Message:
no people met this issue too.
https://issues.apache.org/activemq/browse/AMQ-1763
|
|
|
Re: uses virtual topic and ClientAcknowledge to submit the message occured probem
by magellings
::
Rate this Message:
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
|
|
|
Re: uses virtual topic and ClientAcknowledge to submit themessage occured probem
by semog
::
Rate this Message:
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@...> Date: Mon, 29 Jun 2009 10:12:58 To: <users@...> 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. |
|
|
Re: uses virtual topic and ClientAcknowledge to submit themessage occured probem
by magellings
::
Rate this Message:
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)
|
|
|
Re: uses virtual topic and ClientAcknowledge to submit themessage occured probem
by Timothy Bish
::
Rate this Message:
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 themessageoccured probem
by semog
::
Rate this Message:
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 <mark.gellings@...> Date: Mon, 29 Jun 2009 11:56:20 To: <users@...> 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 <mark.gellings@...> > > Date: Mon, 29 Jun 2009 10:12:58 > To: <users@...> > 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 themessageoccured probem
by magellings
::
Rate this Message:
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.
|
|
|
Re: uses virtual topic and ClientAcknowledge to submit themessageoccured probem
by magellings
::
Rate this Message:
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?
|
| Free embeddable forum powered by Nabble | Forum Help |
