Hi
I've just setup a three ActiveMQ 5.10 nodes in master/slave configuration
with replicated LevelDB. I've also setup the Zookeeper server in the same
nodes. Zookeeper seems running pretty much okay as far I can see.
When I crank up the first ActiveMQ node, it stops waiting for another node
in order to promote the master. So far so good!.
Now, as soon as I started the second node, the previous ActiveMQ node
attempts to be the master but it throws an exception, stops LevelDB and gets
stuck. I am not sure why, does anyone have an idea about what is happening?
Cheers
<persistenceAdapter>
<replicatedLevelDB
directory="activemq-data"
replicas="3"
bind="tcp://0.0.0.0:0"
zkAddress="161.72.45.125:2181,161.72.45.126:2181,161.72.45.127:2181"
zkPassword="password"
zkPath="/opt/activemq/leveldb-stores"
hostname="activemq1" />
</persistenceAdapter>
2014-11-18 13:32:56,018 | INFO | Not enough cluster members connected to
elect a master. | org.apache.activemq.leveldb.replicated.MasterElector |
main-EventThread
2014-11-18 13:33:08,790 | INFO | Not enough cluster members have reported
their update positions yet. |
org.apache.activemq.leveldb.replicated.MasterElector | main-EventThread
2014-11-18 13:33:08,814 | INFO | Promoted to master |
org.apache.activemq.leveldb.replicated.MasterElector | main-EventThread
2014-11-18 13:33:08,973 | WARN | listeners are taking too long to process
the events |
org.apache.activemq.leveldb.replicated.groups.ChangeListenerSupport |
main-EventThread
2014-11-18 13:33:08,975 | WARN | listeners are taking too long to process
the events |
org.apache.activemq.leveldb.replicated.groups.ChangeListenerSupport |
main-EventThread
2014-11-18 13:33:09,010 | INFO | Using the pure java LevelDB
implementation. | org.apache.activemq.leveldb.LevelDBClient | ActiveMQ
BrokerService[telemetry] Task-1
2014-11-18 13:33:09,099 | INFO | No IOExceptionHandler registered, ignoring
IO exception | org.apache.activemq.broker.BrokerService | LevelDB
IOException handler.
java.io.IOException:
com.google.common.base.Objects.firstNonNull(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
at
org.apache.activemq.util.IOExceptionSupport.create(IOExceptionSupport.java:39)[activemq-client-5.10.0.jar:5.10.0]
at
org.apache.activemq.leveldb.LevelDBClient.might_fail(LevelDBClient.scala:552)[activemq-leveldb-store-5.10.0.jar:5.10.0]
at
org.apache.activemq.leveldb.LevelDBClient.replay_init(LevelDBClient.scala:657)[activemq-leveldb-store-5.10.0.jar:5.10.0]
at
org.apache.activemq.leveldb.LevelDBClient.start(LevelDBClient.scala:558)[activemq-leveldb-store-5.10.0.jar:5.10.0]
at
org.apache.activemq.leveldb.DBManager.start(DBManager.scala:648)[activemq-leveldb-store-5.10.0.jar:5.10.0]
at
org.apache.activemq.leveldb.LevelDBStore.doStart(LevelDBStore.scala:235)[activemq-leveldb-store-5.10.0.jar:5.10.0]
at
org.apache.activemq.leveldb.replicated.MasterLevelDBStore.doStart(MasterLevelDBStore.scala:110)[activemq-leveldb-store-5.10.0.jar:5.10.0]
at
org.apache.activemq.util.ServiceSupport.start(ServiceSupport.java:55)[activemq-client-5.10.0.jar:5.10.0]
at
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$$anonfun$start_master$1.apply$mcV$sp(ElectingLevelDBStore.scala:226)[activemq-leveldb-store-5.10.0.jar:5.10.0]
at
org.fusesource.hawtdispatch.package$$anon$4.run(hawtdispatch.scala:330)[hawtdispatch-scala-2.11-1.21.jar:1.21]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)[:1.7.0_71]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)[:1.7.0_71]
at java.lang.Thread.run(Thread.java:745)[:1.7.0_71]
2014-11-18 13:33:09,119 | INFO | Stopped
LevelDB[/opt/apache-activemq-5.10.0/ntcs-broker/telemetry/activemq-data] |
org.apache.activemq.leveldb.LevelDBStore | LevelDB IOException handler.
(END)
--
View this message in context:
http://activemq.2283324.n4.nabble.com/ActiveMQ-stucks-with-replicated-LevelDB-on-startup-tp4687634.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
