activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Gary Tully <gary.tu...@gmail.com>
Subject Re: AMQ DataStore exception leading to Java.IO.EOFException
Date Thu, 08 Apr 2010 22:42:24 GMT
http://activemq.apache.org/maven/5.3.1/activemq-core/apidocs/

On 8 April 2010 19:28, sk123 <skuna@savi.com> wrote:

>
> Has the API for Active MQ 5.3.1 been published?
> If so please point me to it.
>
>
> Thanks in Advance
> Sunita
>
>
> Gary Tully wrote:
> >
> > kahaDB is only in versions 5.3 and up. Impl
> > class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
> >
> > On 8 April 2010 00:16, sk123 <skuna@savi.com> wrote:
> >
> >>
> >> Hi,
> >>
> >> Is KahaPersistenceAdapter the class that represents KahaDB?
> >>
> >> The broker is loaded and configure programmatically. Currently, Active
> MQ
> >> 5.1 and AMQ is being used.
> >>
> >> Appreciate you reply.
> >>
> >> Thanks
> >> Sunita
> >>
> >> rajdavies wrote:
> >> >
> >> > Yes - though make sure its KahaDB - there's an older store called Kaha
> >> -
> >> > we aren't very good at thinking up new names!
> >> > On 17 Mar 2010, at 01:15, Sebastian Rodriguez wrote:
> >> >
> >> >> 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
> >> >
> >> >
> >> >
> >>
> >> --
> >> View this message in context:
> >>
> http://old.nabble.com/AMQ-DataStore-exception-leading-to-Java.IO.EOFException-tp27913055p28172148.html
> >> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
> >>
> >>
> >
> >
> > --
> > http://blog.garytully.com
> >
> > Open Source Integration
> > http://fusesource.com
> >
> >
>
> --
> View this message in context:
> http://old.nabble.com/AMQ-DataStore-exception-leading-to-Java.IO.EOFException-tp27913055p28182646.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
>


-- 
http://blog.garytully.com

Open Source Integration
http://fusesource.com

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