activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From magellings <mark.gelli...@qg.com>
Subject Re: uses virtual topic and ClientAcknowledge to submit themessage occured probem
Date Mon, 29 Jun 2009 18:56:20 GMT

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

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


Mime
View raw message