Give me the exact steps to reproduce... How many queues, how many messages sent to each before failover, etc etc... Exact steps.
On Sunday, May 26, 2013, heimdull wrote: > I have been testing this setup with one of our clusters and I have found an > issue where failover breaks one or two of our queues. > > I have a setup where I'm running latest snapshot with Zookeeper and setup > for replicated leveldb. When I run a activemq stop (using wrapper) my > active > master shutdown fine and my slave recognizes this and starts process of > going active. When I can get back into my web console I see all queues like > expected BUT there are usually one queue with 50 messages that are stuck, > it > has consumers but they are not consumed. When trying to view contents of > queue with jmx or web console it just hangs and times-out. If I delete this > queue its recreated and everything starts working again. > > Only log info I see are these: > > 2013-05-26 07:09:38,850 | WARN | Async error occurred: > java.lang.IllegalArgumentException: The subscription does not exist: > ID:tn11-27191-1368304518500-1:6:5:1 | > org.apache.activemq.broker.TransportConnection.Service | ActiveMQ NIO > Worker > 38 > java.lang.IllegalArgumentException: The subscription does not exist: ID > > > Here is my env: > > INFO | jvm 1 | 2013/05/26 07:09:34 | INFO | Client > environment:zookeeper.version=3.4.3-1240972, built on 02/06/2012 10:48 GMT > INFO | jvm 1 | 2013/05/26 07:09:34 | INFO | Client > environment:java.version=1.7.0_21 > INFO | jvm 1 | 2013/05/26 07:09:34 | INFO | Client > environment:java.vendor=Oracle Corporation > INFO | jvm 1 | 2013/05/26 07:09:34 | INFO | Client > environment:java.home=/opt/jdk/jre > INFO | jvm 1 | 2013/05/26 07:09:34 | INFO | Client > > environment:java.class.path=/opt/activemq/bin/wrapper.jar:/opt/activemq/bin/activemq.jar > INFO | jvm 1 | 2013/05/26 07:09:34 | INFO | Client > environment:java.library.path=/opt/activemq/bin/linux-x86-64/ > INFO | jvm 1 | 2013/05/26 07:09:34 | INFO | Client > environment:java.io.tmpdir=/tmp > INFO | jvm 1 | 2013/05/26 07:09:34 | INFO | Client > environment:java.compiler=<NA> > INFO | jvm 1 | 2013/05/26 07:09:34 | INFO | Client > environment:os.name=Linux > INFO | jvm 1 | 2013/05/26 07:09:34 | INFO | Client > environment:os.arch=amd64 > INFO | jvm 1 | 2013/05/26 07:09:34 | INFO | Client > environment:os.version=3.2.0-37-generic > INFO | jvm 1 | 2013/05/26 07:09:34 | INFO | Client > environment:user.name=activemq > INFO | jvm 1 | 2013/05/26 07:09:34 | INFO | Client > environment:user.home=/home/activemq > INFO | jvm 1 | 2013/05/26 07:09:34 | INFO | Client > environment:user.dir=/opt/activemq/bin/linux-x86-64 > > I tried this we the three latest Snapshots they all do the same. > > (And in an unrelated error When starting latest 5.9-snapshot I get a > message > that amqp is not recognized.) > > > > > -- > View this message in context: > http://activemq.2283324.n4.nabble.com/Activemq-5-9-leveldb-replication-issue-tp4667495.html > Sent from the ActiveMQ - User mailing list archive at Nabble.com. > -- *Christian Posta* http://www.christianposta.com/blog twitter: @christianposta