Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@activemq.apache.org
Received-SPF: pass (nike.apache.org: domain of lists@nabble.com designates
 216.139.236.158 as permitted sender)
Message-ID: <24260431.post@talk.nabble.com>
Date: Mon, 29 Jun 2009 12:57:34 -0700 (PDT)
From: magellings <mark.gellings@qg.com>
To: users@activemq.apache.org
Subject: Re: uses virtual topic   and ClientAcknowledge to submit
 themessageoccured probem
In-Reply-To: 
 <994378346-1246303112-cardhu_decombobulator_blackberry.rim.net-1698475818-@bxe1036.bisx.prod.on.blackberry>
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit
References: <22486742.post@talk.nabble.com> <24258128.post@talk.nabble.com>
 <226165218-1246296134-cardhu_decombobulator_blackberry.rim.net-496444014-@bxe1036.bisx.prod.on.blackberry>
 <24259354.post@talk.nabble.com>
 <994378346-1246303112-cardhu_decombobulator_blackberry.rim.net-1698475818-@bxe1036.bisx.prod.on.blackberry>


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 <mark.gellings@qg.com>
> 
> Date: Mon, 29 Jun 2009 11:56:20 
> To: <users@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 <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.
> 
> 
> 

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