You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2013/06/03 17:46:48 UTC
svn commit: r1489036 -
/activemq/trunk/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/IDERunner.java
Author: chirino
Date: Mon Jun 3 15:46:48 2013
New Revision: 1489036
URL: http://svn.apache.org/r1489036
Log:
Fixes compiler error in last leveldb fix.
Modified:
activemq/trunk/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/IDERunner.java
Modified: activemq/trunk/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/IDERunner.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/IDERunner.java?rev=1489036&r1=1489035&r2=1489036&view=diff
==============================================================================
--- activemq/trunk/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/IDERunner.java (original)
+++ activemq/trunk/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/IDERunner.java Mon Jun 3 15:46:48 2013
@@ -17,7 +17,7 @@
package org.apache.activemq.transport.amqp;
import org.apache.activemq.broker.BrokerService;
-import org.apache.activemq.leveldb.LevelDBStore;
+// import org.apache.activemq.leveldb.LevelDBStore;
import java.io.File;
@@ -26,10 +26,10 @@ public class IDERunner {
public static void main(String[]args) throws Exception {
BrokerService bs = new BrokerService();
bs.addConnector("tcp://localhost:61616");
- LevelDBStore store = new LevelDBStore();
- store.setDirectory(new File("target/activemq-data/haleveldb"));
- bs.setPersistenceAdapter(store);
- bs.deleteAllMessages();
+ // LevelDBStore store = new LevelDBStore();
+ // store.setDirectory(new File("target/activemq-data/haleveldb"));
+ // bs.setPersistenceAdapter(store);
+ // bs.deleteAllMessages();
bs.start();
bs.waitUntilStopped();
}