Apache/activemq
1
0
Fork 0
mirror of https://github.com/apache/activemq.git synced 2025-02-10 03:56:21 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fixes compiler error in last leveldb fix.

Browse Source 
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1489036 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Hiram R. Chirino 2013-06-03 15:46:48 +00:00
parent acc51e693e
commit 3bfb4426b0
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/IDERunner.java
View File

@ -17,7 +17,7 @@
package org.apache.activemq.transport.amqp; package org.apache.activemq.transport.amqp;
import org.apache.activemq.broker.BrokerService; import org.apache.activemq.broker.BrokerService;
import org.apache.activemq.leveldb.LevelDBStore; // import org.apache.activemq.leveldb.LevelDBStore;
import java.io.File; import java.io.File;
@ -26,10 +26,10 @@ public class IDERunner {
public static void main(String[]args) throws Exception { public static void main(String[]args) throws Exception {
BrokerService bs = new BrokerService(); BrokerService bs = new BrokerService();
bs.addConnector("tcp://localhost:61616"); bs.addConnector("tcp://localhost:61616");
LevelDBStore store = new LevelDBStore(); // LevelDBStore store = new LevelDBStore();
store.setDirectory(new File("target/activemq-data/haleveldb")); // store.setDirectory(new File("target/activemq-data/haleveldb"));
bs.setPersistenceAdapter(store); // bs.setPersistenceAdapter(store);
bs.deleteAllMessages(); // bs.deleteAllMessages();
bs.start(); bs.start();
bs.waitUntilStopped(); bs.waitUntilStopped();
} }