You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@activemq.apache.org by "Gary Tully (JIRA)" <ji...@apache.org> on 2010/07/26 15:50:52 UTC
[jira] Created: (AMQ-2850) AMQ2149Test failure shows issue with
topic recovery
AMQ2149Test failure shows issue with topic recovery
---------------------------------------------------
Key: AMQ-2850
URL: https://issues.apache.org/activemq/browse/AMQ-2850
Project: ActiveMQ
Issue Type: Test
Components: Test Cases
Affects Versions: 5.4.0
Reporter: Gary Tully
Assignee: Gary Tully
Fix For: 5.4.0
regression with this test:
{code}Caused by: java.lang.RuntimeException: java.lang.RuntimeException: java.lang.IllegalStateException: Message id ID:minerva.apache.org-56711-1280031958874-3:39:1:1:103 could not be recovered from the data store for: topic://test.dest.9 - already dispatched
at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.reset(AbstractStoreCursor.java:113)
at org.apache.activemq.broker.region.cursors.StoreDurableSubscriberCursor.reset(StoreDurableSubscriberCursor.java:240)
at org.apache.activemq.broker.region.PrefetchSubscription.dispatchPending(PrefetchSubscription.java:572)
at org.apache.activemq.broker.region.PrefetchSubscription.add(PrefetchSubscription.java:156)
at org.apache.activemq.broker.region.DurableTopicSubscription.add(DurableTopicSubscription.java:204)
at org.apache.activemq.broker.region.policy.SimpleDispatchPolicy.dispatch(SimpleDispatchPolicy.java:47)
at org.apache.activemq.broker.region.Topic.dispatch(Topic.java:628)
at org.apache.activemq.broker.region.Topic.doMessageSend(Topic.java:475)
at org.apache.activemq.broker.region.Topic.send(Topic.java:411)
at org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:365)
at org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:494)
at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:129)
at org.apache.activemq.broker.scheduler.SchedulerBroker.send(SchedulerBroker.java:136)
at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:129)
at org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:95)
at org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:230)
at org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:135)
at org.apache.activemq.broker.TransportConnection.processMessage(TransportConnection.java:457)
at org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:661)
at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:306)
at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:182)
at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:69)
at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113)
at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:217)
at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:219)
at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:201)
{code}
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
[jira] Commented: (AMQ-2850) AMQ2149Test failure shows issue with
topic recovery
Posted by "Gary Tully (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/activemq/browse/AMQ-2850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=60946#action_60946 ]
Gary Tully commented on AMQ-2850:
---------------------------------
issue is ack before add reference is complete, subsequent add would leave a dangling reference. Duplicate detection is now used to filter the add. Issue in amq store r979775.
A variant of the test case with KahaDB has some issues that needs some more investigation.
> AMQ2149Test failure shows issue with topic recovery
> ---------------------------------------------------
>
> Key: AMQ-2850
> URL: https://issues.apache.org/activemq/browse/AMQ-2850
> Project: ActiveMQ
> Issue Type: Test
> Components: Test Cases
> Affects Versions: 5.4.0
> Reporter: Gary Tully
> Assignee: Gary Tully
> Fix For: 5.4.0
>
>
> regression with this test:
> {code}Caused by: java.lang.RuntimeException: java.lang.RuntimeException: java.lang.IllegalStateException: Message id ID:minerva.apache.org-56711-1280031958874-3:39:1:1:103 could not be recovered from the data store for: topic://test.dest.9 - already dispatched
> at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.reset(AbstractStoreCursor.java:113)
> at org.apache.activemq.broker.region.cursors.StoreDurableSubscriberCursor.reset(StoreDurableSubscriberCursor.java:240)
> at org.apache.activemq.broker.region.PrefetchSubscription.dispatchPending(PrefetchSubscription.java:572)
> at org.apache.activemq.broker.region.PrefetchSubscription.add(PrefetchSubscription.java:156)
> at org.apache.activemq.broker.region.DurableTopicSubscription.add(DurableTopicSubscription.java:204)
> at org.apache.activemq.broker.region.policy.SimpleDispatchPolicy.dispatch(SimpleDispatchPolicy.java:47)
> at org.apache.activemq.broker.region.Topic.dispatch(Topic.java:628)
> at org.apache.activemq.broker.region.Topic.doMessageSend(Topic.java:475)
> at org.apache.activemq.broker.region.Topic.send(Topic.java:411)
> at org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:365)
> at org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:494)
> at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:129)
> at org.apache.activemq.broker.scheduler.SchedulerBroker.send(SchedulerBroker.java:136)
> at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:129)
> at org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:95)
> at org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:230)
> at org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:135)
> at org.apache.activemq.broker.TransportConnection.processMessage(TransportConnection.java:457)
> at org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:661)
> at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:306)
> at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:182)
> at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:69)
> at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113)
> at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:217)
> at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
> at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:219)
> at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:201)
> {code}
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
[jira] Resolved: (AMQ-2850) AMQ2149Test failure shows issue with
topic recovery
Posted by "Gary Tully (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/activemq/browse/AMQ-2850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Gary Tully resolved AMQ-2850.
-----------------------------
Resolution: Fixed
added kahaDB variant and fix in r980462
> AMQ2149Test failure shows issue with topic recovery
> ---------------------------------------------------
>
> Key: AMQ-2850
> URL: https://issues.apache.org/activemq/browse/AMQ-2850
> Project: ActiveMQ
> Issue Type: Test
> Components: Test Cases
> Affects Versions: 5.4.0
> Reporter: Gary Tully
> Assignee: Gary Tully
> Fix For: 5.4.0
>
>
> regression with this test:
> {code}Caused by: java.lang.RuntimeException: java.lang.RuntimeException: java.lang.IllegalStateException: Message id ID:minerva.apache.org-56711-1280031958874-3:39:1:1:103 could not be recovered from the data store for: topic://test.dest.9 - already dispatched
> at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.reset(AbstractStoreCursor.java:113)
> at org.apache.activemq.broker.region.cursors.StoreDurableSubscriberCursor.reset(StoreDurableSubscriberCursor.java:240)
> at org.apache.activemq.broker.region.PrefetchSubscription.dispatchPending(PrefetchSubscription.java:572)
> at org.apache.activemq.broker.region.PrefetchSubscription.add(PrefetchSubscription.java:156)
> at org.apache.activemq.broker.region.DurableTopicSubscription.add(DurableTopicSubscription.java:204)
> at org.apache.activemq.broker.region.policy.SimpleDispatchPolicy.dispatch(SimpleDispatchPolicy.java:47)
> at org.apache.activemq.broker.region.Topic.dispatch(Topic.java:628)
> at org.apache.activemq.broker.region.Topic.doMessageSend(Topic.java:475)
> at org.apache.activemq.broker.region.Topic.send(Topic.java:411)
> at org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:365)
> at org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:494)
> at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:129)
> at org.apache.activemq.broker.scheduler.SchedulerBroker.send(SchedulerBroker.java:136)
> at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:129)
> at org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:95)
> at org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:230)
> at org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:135)
> at org.apache.activemq.broker.TransportConnection.processMessage(TransportConnection.java:457)
> at org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:661)
> at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:306)
> at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:182)
> at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:69)
> at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113)
> at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:217)
> at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
> at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:219)
> at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:201)
> {code}
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.