activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Sebastian Rodriguez <srodrig...@gmail.com>
Subject Re: AMQ DataStore exception leading to Java.IO.EOFException
Date Wed, 17 Mar 2010 01:15:52 GMT
Do you guys think switching to Kaha Data Store could solve this issue ( <=>
this issue is AmqDatastore specific?)

On 16 March 2010 11:00, Sebastian Rodriguez <srodrigu85@gmail.com> wrote:

> Dear all,
> I come back to you to look for pointers on possible causes that can lead me
> to receive this kind of exception.
> I'm using Apache.ActiveMQ 5.3.1, with Apache.NMS.ActiveMQ 1.2.0.
> I'm using ActiveMQ for communicating in a SOAP application: the servers are
> in Network of Brokers configuration, the clients have an embedded ActiveMQ.
>
> Some of the members of the network of brokers are not always available, and
> when reconnecting I get a lot of  these kind of exceptions one after the
> other:
>
> INFO   | jvm 1    | 2010/03/15 19:12:41 | WARN  AMQMessageStore
>    - Message could not be added to long term store: Index: 1, Size: 1
> INFO   | jvm 1    | 2010/03/15 19:12:41 |
> java.lang.IndexOutOfBoundsException: Index: 1, Size: 1
> INFO   | jvm 1    | 2010/03/15 19:12:41 | at
> java.util.ArrayList.RangeCheck(Unknown Source)
> INFO   | jvm 1    | 2010/03/15 19:12:41 | at
> java.util.ArrayList.get(Unknown Source)
> INFO   | jvm 1    | 2010/03/15 19:12:41 | at
> org.apache.activemq.kaha.impl.index.hash.HashPage.getHashEntry(HashPage.java:181)
> INFO   | jvm 1    | 2010/03/15 19:12:41 | at
> org.apache.activemq.kaha.impl.index.hash.HashPageInfo.getHashEntry(HashPageInfo.java:78)
> INFO   | jvm 1    | 2010/03/15 19:12:41 | at
> org.apache.activemq.kaha.impl.index.hash.HashBin.getHashEntry(HashBin.java:247)
> INFO   | jvm 1    | 2010/03/15 19:12:41 | at
> org.apache.activemq.kaha.impl.index.hash.HashBin.remove(HashBin.java:164)
> INFO   | jvm 1    | 2010/03/15 19:12:41 | at
> org.apache.activemq.kaha.impl.index.hash.HashIndex.remove(HashIndex.java:303)
> INFO   | jvm 1    | 2010/03/15 19:12:41 | at
> org.apache.activemq.kaha.impl.container.MapContainerImpl.remove(MapContainerImpl.java:337)
> INFO   | jvm 1    | 2010/03/15 19:12:41 | at
> org.apache.activemq.kaha.impl.container.MapContainerImpl.place(MapContainerImpl.java:414)
> INFO   | jvm 1    | 2010/03/15 19:12:41 | at
> org.apache.activemq.store.kahadaptor.TopicSubContainer.add(TopicSubContainer.java:62)
> INFO   | jvm 1    | 2010/03/15 19:12:41 | at
> org.apache.activemq.store.kahadaptor.KahaTopicReferenceStore.addMessageReference(KahaTopicReferenceStore.java:104)
> INFO   | jvm 1    | 2010/03/15 19:12:41 | at
> org.apache.activemq.store.amq.AMQMessageStore$4.execute(AMQMessageStore.java:383)
> INFO   | jvm 1    | 2010/03/15 19:12:41 | at
> org.apache.activemq.util.TransactionTemplate.run(TransactionTemplate.java:44)
> INFO   | jvm 1    | 2010/03/15 19:12:41 | at
> org.apache.activemq.store.amq.AMQMessageStore.doAsyncWrite(AMQMessageStore.java:373)
> INFO   | jvm 1    | 2010/03/15 19:12:41 | at
> org.apache.activemq.store.amq.AMQMessageStore.asyncWrite(AMQMessageStore.java:339)
> INFO   | jvm 1    | 2010/03/15 19:12:41 | at
> org.apache.activemq.store.amq.AMQMessageStore$1.iterate(AMQMessageStore.java:90)
> INFO   | jvm 1    | 2010/03/15 19:12:41 | at
> org.apache.activemq.thread.DedicatedTaskRunner.runTask(DedicatedTaskRunner.java:98)
> INFO   | jvm 1    | 2010/03/15 19:12:41 | at
> org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRunner.java:36)
>
> Until at some point I get this message:
>
> 2010-03-16 09:19:44,608 [216.10.21:31616] WARN  DemandForwardingBridge
>     - Network connection between vm://client1 and tcp://broker1:31616
> shutdown due to a remote error: java.io.EOFException
> 2010-03-16 09:19:44,623 [216.10.21:31616] INFO  DemandForwardingBridge
>     - client1 bridge to client2 stopped
> 2010-03-16 09:19:44,623 [r$Worker@c0bc3a] INFO  DiscoveryNetworkConnector
>      - Establishing network connection from vm://client1 to
> tcp://broker1:31616
> 2010-03-16 09:19:45,826 [r$Worker@c0bc3a] WARN  DiscoveryNetworkConnector
>      - Could not start network bridge between: vm://client1 and:
> tcp://broker1:31616 due to: java.net.ConnectException: Connection refused:
> connect
>
> Then it tries to reconnect and reconnect
> At that point the Service is "hang", meaning the service seems to be
> running, yet when looking for connections, they are all gone. My client will
> not receive any more messages from the server.
>
> After rebooting the service, it will take incredibly long to recover. This
> is caused I guess also because right now I'm using the AMQDataStore (I
> believe now it's recommended to switch to the KahaStore).
>
> What can cause this message problem and is it the reason that after a lot
> of these exceptions i receive the EOF Exception?
>
> Thank you very much for your help,
>  --
> Sebastien Rodriguez
>



-- 
Sebastien Rodriguez

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message