http://activemq.apache.org/maven/5.3.1/activemq-core/apidocs/
On 8 April 2010 19:28, sk123 <[email protected]> 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 <[email protected]> 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 <[email protected]> > >> 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$wor...@c0bc3a] INFO > >> >>> DiscoveryNetworkConnector > >> >>> - Establishing network connection from vm://client1 to > >> >>> tcp://broker1:31616 > >> >>> 2010-03-16 09:19:45,826 [r$wor...@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
