[ 
https://issues.apache.org/jira/browse/AMQ-6019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Timothy Bish closed AMQ-6019.
-----------------------------
    Resolution: Cannot Reproduce

Reported as not reproducible on a newer broker.

> TheListIndex is not loaded exception under heavier load
> -------------------------------------------------------
>
>                 Key: AMQ-6019
>                 URL: https://issues.apache.org/jira/browse/AMQ-6019
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Broker, KahaDB
>    Affects Versions: 5.10.0
>         Environment: AcitveMQ 5.10.0 on Windows Server 2012R2 DataCenter
>            Reporter: Octavian
>
> Hello,
> I'm trying to run the performance test with posting 1,000,000 messages from 4 
> producers to ActiveMQ. Many times I'm getting the following exception in 
> ActiveMQ Broker logs and it looks like the broker is not accepting any more 
> messages:
> 2015-10-22 09:30:45,314 | WARN  | Async error occurred:  | 
> org.apache.activemq.broker.TransportConnection.Service | ActiveMQ Transport: 
> tcp:///10.80.35.179:56140@20039
> java.lang.RuntimeException: java.lang.IllegalStateException: TheListIndex is 
> not loaded
>       at 
> org.apache.activemq.broker.region.cursors.FilePendingMessageCursor.tryAddMessageLast(FilePendingMessageCursor.java:244)[activemq-broker-5.10.0.jar:5.10.0]
>       at 
> org.apache.activemq.broker.region.cursors.FilePendingMessageCursor.addMessageLast(FilePendingMessageCursor.java:207)[activemq-broker-5.10.0.jar:5.10.0]
>       at 
> org.apache.activemq.broker.region.Queue.sendMessage(Queue.java:1855)[activemq-broker-5.10.0.jar:5.10.0]
>       at 
> org.apache.activemq.broker.region.Queue.doMessageSend(Queue.java:939)[activemq-broker-5.10.0.jar:5.10.0]
>       at 
> org.apache.activemq.broker.region.Queue.send(Queue.java:733)[activemq-broker-5.10.0.jar:5.10.0]
>       at 
> org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:424)[activemq-broker-5.10.0.jar:5.10.0]
>       at 
> org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:445)[activemq-broker-5.10.0.jar:5.10.0]
>       at 
> org.apache.activemq.broker.jmx.ManagedRegionBroker.send(ManagedRegionBroker.java:297)[activemq-broker-5.10.0.jar:5.10.0]
>       at 
> org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:147)[activemq-broker-5.10.0.jar:5.10.0]
>       at 
> org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:96)[activemq-broker-5.10.0.jar:5.10.0]
>       at 
> org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:307)[activemq-broker-5.10.0.jar:5.10.0]
>       at 
> org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:152)[activemq-broker-5.10.0.jar:5.10.0]
>       at 
> org.apache.activemq.broker.TransportConnection.processMessage(TransportConnection.java:496)[activemq-broker-5.10.0.jar:5.10.0]
>       at 
> org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:756)[activemq-client-5.10.0.jar:5.10.0]
>       at 
> org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:294)[activemq-broker-5.10.0.jar:5.10.0]
>       at 
> org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:148)[activemq-broker-5.10.0.jar:5.10.0]
>       at 
> org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50)[activemq-client-5.10.0.jar:5.10.0]
>       at 
> org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113)[activemq-client-5.10.0.jar:5.10.0]
>       at 
> org.apache.activemq.transport.AbstractInactivityMonitor.onCommand(AbstractInactivityMonitor.java:270)[activemq-client-5.10.0.jar:5.10.0]
>       at 
> org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)[activemq-client-5.10.0.jar:5.10.0]
>       at 
> org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:214)[activemq-client-5.10.0.jar:5.10.0]
>       at 
> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:196)[activemq-client-5.10.0.jar:5.10.0]
>       at java.lang.Thread.run(Unknown Source)[:1.8.0_11]
> For example I'm getting 131191 messages out of 1000,000 on the queue and the 
> performance test is freezing.
> I'm running the test with the following command:
> mvn activemq-perf:producer -Dfactory.brokerURL=tcp://hostname:20039 
> -DsysTest.numClients=4 -Dproducer.destName=queue://test 
> -Dproducer.deliveryMode=persistent -Dfactory.useAsyncSend=true
> I've changed the activemq.xml persistenceAdapter as shown:
>         <persistenceAdapter>
>             <kahaDB directory="${activemq.data}/kahadb" 
> enableJournalDiskSyncs="false" indexWriteBatchSize="10000" 
> indexCacheSize="1000"/>
>         </persistenceAdapter>
> Thanks,
> Octavian



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to