[
https://issues.apache.org/jira/browse/AMQ-5900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Lindwall updated AMQ-5900:
-------------------------------
Attachment: ActiveMQFailOverMessageSender.java
My producer
> LevelDB integration does not work in Solaris
> --------------------------------------------
>
> Key: AMQ-5900
> URL: https://issues.apache.org/jira/browse/AMQ-5900
> Project: ActiveMQ
> Issue Type: Bug
> Components: activemq-leveldb-store
> Affects Versions: 5.9.0, 5.11.1
> Environment: Solaris 5.11, jdk 1.7_60
> Reporter: John Lindwall
> Attachments: ActiveMQFailOverMessageSender.java
>
>
> I had 3 activemq nodes running using leveldb replication. I connected a
> client that listened for messages, but I did not send any messages at all.
> I then used "kill -9" to kill the master node. The client failed to
> reconnect even though I used a failover url. In the node2 activemq.log I see
> the following, as it attempted to become the new master:
> 2015-07-22 17:57:19,334 | INFO | Attaching to master:
> tcp://172.10.10.10:61619 |
> org.apache.activemq.leveldb.replicated.SlaveLevelDBStore |
> hawtdispatch-DEFAULT-1
> 2015-07-22 17:57:19,338 | WARN | Unexpected session error:
> java.net.ConnectException: Connection refused |
> org.apache.activemq.leveldb.replicated.SlaveLevelDBStore |
> hawtdispatch-DEFAULT-1
> 2015-07-22 17:57:20,044 | INFO | Not enough cluster members have reported
> their update positions yet. |
> org.apache.activemq.leveldb.replicated.MasterElector | main-EventThread
> 2015-07-22 17:57:20,059 | INFO | Slave stopped |
> org.apache.activemq.leveldb.replicated.MasterElector | ActiveMQ
> BrokerService[xifin] Task-3
> 2015-07-22 17:57:20,061 | INFO | Not enough cluster members have reported
> their update positions yet. |
> org.apache.activemq.leveldb.replicated.MasterElector | ActiveMQ
> BrokerService[xifin] Task-3
> 2015-07-22 17:57:20,068 | INFO | Not enough cluster members have reported
> their update positions yet. |
> org.apache.activemq.leveldb.replicated.MasterElector | main-EventThread
> 2015-07-22 17:57:20,087 | INFO | Promoted to master |
> org.apache.activemq.leveldb.replicated.MasterElector | main-EventThread
> 2015-07-22 17:57:20,124 | INFO | Using the pure java LevelDB implementation.
> | org.apache.activemq.leveldb.LevelDBClient | ActiveMQ BrokerService[xifin]
> Task-3
> 2015-07-22 17:57:20,380 | INFO | No IOExceptionHandler registered, ignoring
> IO exception | org.apache.activemq.broker.BrokerService | LevelDB IOException
> handler.
> java.io.IOException: org.iq80.snappy.CorruptionException: Invalid copy offset
> for opcode starting at 8
> at
> org.apache.activemq.util.IOExceptionSupport.create(IOExceptionSupport.java:39)[activemq-client-5.11.1.jar:5.11.1]
>
> at
> org.apache.activemq.leveldb.LevelDBClient.might_fail(LevelDBClient.scala:552)[activemq-leveldb-store-5.11.1.jar:5.11.1]
>
> at
> org.apache.activemq.leveldb.LevelDBClient.replay_init(LevelDBClient.scala:667)[activemq-leveldb-store-5.11.1.jar:5.11.1]
>
> at
> org.apache.activemq.leveldb.LevelDBClient.start(LevelDBClient.scala:558)[activemq-leveldb-store-5.11.1.jar:5.11.1]
>
> at
> org.apache.activemq.leveldb.DBManager.start(DBManager.scala:648)[activemq-leveldb-store-5.11.1.jar:5.11.1]
>
> at
> org.apache.activemq.leveldb.LevelDBStore.doStart(LevelDBStore.scala:312)[activemq-leveldb-store-5.11.1.jar:5.11.1]
>
> at
> org.apache.activemq.leveldb.replicated.MasterLevelDBStore.doStart(MasterLevelDBStore.scala:110)[activemq-leveldb-store-5.11.1.jar:5.11.1]
>
> at
> org.apache.activemq.util.ServiceSupport.start(ServiceSupport.java:55)[activemq-client-5.11.1.jar:5.11.1]
>
> at
> org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$$anonfun$start_master$1.apply$mcV$sp(ElectingLevelDBStore.scala:230)[activemq-leveldb-store-5.11.1.jar:5.11.1]
>
> 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_60]
>
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)[:1.7.0_60]
>
> at java.lang.Thread.run(Thread.java:745)[:1.7.0_60]
> 2015-07-22 17:57:20,400 | INFO | Stopped
> LevelDB[/home/jlindwall/servers/activemq-replicated-leveldb-cluster/node2/data/LevelDB]
> | org.apache.activemq.leveldb.LevelDBStore | LevelDB IOException handler.
> See also:
> http://activemq.2283324.n4.nabble.com/Leveldb-on-Solaris-td4677824.html#a4699723
> Thank you.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
