[jira] [Updated] (AMQ-5900) LevelDB integration does not work in Solaris

["John Lindwall (JIRA)" <ji...@apache.org>]

     [ 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)