updated for https://issues.apache.org/jira/browse/AMQ-3772

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1302494 13f79535-47bb-0310-9956-ffa450edef68

activemq-core/pom.xml

@@ -92,6 +92,10 @@
       <artifactId>activemq-protobuf</artifactId>
       <optional>false</optional>
     </dependency>
+		<dependency>
+      <groupId>org.fusesource.fuse-extra</groupId>
+      <artifactId>fusemq-leveldb</artifactId>
+    </dependency>
 
     <!-- =============================== -->
     <!-- Optional Dependencies           -->
@@ -172,6 +176,7 @@
       <optional>true</optional>
     </dependency>
 
+    
     <!-- =============================== -->
     <!-- Testing Dependencies            -->
     <!-- =============================== -->

activemq-core/src/main/java/org/apache/activemq/store/leveldb/LevelDBPersistenceAdapter.java

@@ -0,0 +1,30 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.activemq.store.leveldb;
+
+import org.fusesource.mq.leveldb.LevelDBStore;
+
+
+/**
+ * An implementation of {@link org.apache.activemq.store.PersistenceAdapter} designed for use with
+ * LevelDB - Embedded Lightweight Non-Relational Database
+ *
+ * @org.apache.xbean.XBean element="levelDB"
+ *
+ */
+public class LevelDBPersistenceAdapter extends LevelDBStore {
+}

activemq-core/src/test/java/org/apache/activemq/store/leveldb/LevelDBStoreBrokerTest.java

@@ -0,0 +1,68 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.activemq.store.leveldb;
+
+import java.io.File;
+
+import junit.framework.Test;
+import org.apache.activemq.broker.BrokerService;
+import org.apache.activemq.broker.BrokerTest;
+import org.apache.activemq.store.kahadb.KahaDBStore;
+import org.apache.activemq.util.IOHelper;
+import org.fusesource.mq.leveldb.LevelDBStore;
+
+/**
+ * Once the wire format is completed we can test against real persistence storage.
+ * 
+ * 
+ */
+public class LevelDBStoreBrokerTest extends BrokerTest {
+
+    protected void setUp() throws Exception {
+        this.setAutoFail(true);
+        super.setUp();
+    }
+    
+    protected BrokerService createBroker() throws Exception {
+        BrokerService broker = new BrokerService();
+        LevelDBStore levelDBStore = new LevelDBStore();
+        File directory = new File("target/activemq-data/leveldb");
+        IOHelper.deleteChildren(directory);
+        levelDBStore.setDirectory(directory);
+        levelDBStore.deleteAllMessages();
+        broker.setPersistenceAdapter(levelDBStore);
+        return broker;
+    }
+    
+    protected BrokerService createRestartedBroker() throws Exception {
+        BrokerService broker = new BrokerService();
+        KahaDBStore kaha = new KahaDBStore();
+        kaha.setDirectory(new File("target/activemq-data/leveldb"));
+        broker.setPersistenceAdapter(kaha);
+        return broker;
+    }
+    
+    
+    public static Test suite() {
+        return suite(LevelDBStoreBrokerTest.class);
+    }
+    
+    public static void main(String[] args) {
+        junit.textui.TestRunner.run(suite());
+    }
+
+}