Package org.fusesource.mq.leveldb

Examples of org.fusesource.mq.leveldb.LevelDBStore.deleteAllMessages()

41
42
43
44
45
46
47
48
49
50
51
        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 {
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.