activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Jim Gomes (JIRA)" <jira+amq...@apache.org>
Subject [jira] Commented: (AMQNET-150) Unit test failures in the Durable Subscruber test
Date Thu, 28 May 2009 05:37:51 GMT

    [ https://issues.apache.org/activemq/browse/AMQNET-150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=51955#action_51955
] 

Jim Gomes commented on AMQNET-150:
----------------------------------

The TestDurableConsumerSelectorChange() test will fail if it is run more than once with Persistent
messages turned on.  The test will run just fine multiple times when NonPersistent messages
are used.  When Persistent messages are used, the broker will display lots of the following
errors starting with the second run of the test:

{noformat}
"ERROR RecoveryListenerAdapter        - Message id 8815cdfc-1a6d-4d71-ae18-ad841ee8fd44:1:1:2
could not be recovered from the data store - already dispatched"
{noformat}

After several runs of this test, I was able to get the following error from the broker:
{noformat}
ERROR DataManagerImpl                - Looking for key -1 but not found in fileMap: {1=data-topic-acks-1
number = 1 , length = 1156 refCount = -2}
ERROR ListContainerImpl              - Failed to get value for offset=51, key=(-1, -1, 0),
value=(-1, -1, 0), previousItem=-1, nextItem=-1
java.io.IOException: Could not locate data file data-topic-acks--1
        at org.apache.activemq.kaha.impl.data.DataManagerImpl.getDataFile(DataManagerImpl.java:129)
        at org.apache.activemq.kaha.impl.data.SyncDataFileReader.readItem(SyncDataFileReader.java:65)
        at org.apache.activemq.kaha.impl.data.DataManagerImpl.readItem(DataManagerImpl.java:141)
        at org.apache.activemq.kaha.impl.container.ListContainerImpl.getValue(ListContainerImpl.java:856)
        at org.apache.activemq.kaha.impl.container.ListContainerImpl.get(ListContainerImpl.java:680)
        at org.apache.activemq.store.kahadaptor.KahaTopicReferenceStore.removeSubscriberMessageContainer(KahaTopicReferenceStore.java:332)
        at org.apache.activemq.store.kahadaptor.KahaTopicReferenceStore.deleteSubscription(KahaTopicReferenceStore.java:211)
        at org.apache.activemq.store.amq.AMQTopicMessageStore.deleteSubscription(AMQTopicMessageStore.java:183)
        at org.apache.activemq.broker.region.Topic.deleteSubscription(Topic.java:168)
        at org.apache.activemq.broker.region.TopicRegion.removeSubscription(TopicRegion.java:140)
        at org.apache.activemq.broker.region.RegionBroker.removeSubscription(RegionBroker.java:409)
        at org.apache.activemq.broker.BrokerFilter.removeSubscription(BrokerFilter.java:98)
        at org.apache.activemq.broker.BrokerFilter.removeSubscription(BrokerFilter.java:98)
        at org.apache.activemq.broker.BrokerFilter.removeSubscription(BrokerFilter.java:98)
        at org.apache.activemq.broker.MutableBrokerFilter.removeSubscription(MutableBrokerFilter.java:105)
        at org.apache.activemq.broker.TransportConnection.processRemoveSubscription(TransportConnection.java:339)
        at org.apache.activemq.command.RemoveSubscriptionInfo.visit(RemoveSubscriptionInfo.java:83)
        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)
{noformat}

The client reports the following error:

{noformat}
ERROR: Transport Exception: Apache.NMS.ActiveMQ.BrokerException: org.apache.activemq.kaha.RuntimeStoreException
: java.io.IOException: Could not locate data file data-topic-acks--1
{noformat}


> Unit test failures in the Durable Subscruber test
> -------------------------------------------------
>
>                 Key: AMQNET-150
>                 URL: https://issues.apache.org/activemq/browse/AMQNET-150
>             Project: ActiveMQ .Net
>          Issue Type: Bug
>    Affects Versions: 1.0
>         Environment: Windows .Net 3.5 and Mono 2.2  AMQ Broker v5.2
>            Reporter: Timothy Bish
>            Assignee: Jim Gomes
>             Fix For: 1.1
>
>
> The durable subscriber tests fails consistantly with the errors
> Apache.NMS.Test.ConsumerTest.TestDurableConsumerSelectorChange(False):
> Apache.NMS.ActiveMQ.BrokerException : javax.jms.InvalidDestinationException : No durable
subscription exists for: ConsumerTestConsumerId
> Apache.NMS.Test.ConsumerTest.TestDurableConsumerSelectorChange(True):
> Apache.NMS.ActiveMQ.BrokerException : org.apache.activemq.kaha.RuntimeStoreException
: java.io.IOException: Could not locate data file data-topic-acks--1

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.


Mime
View raw message