mirror of https://github.com/apache/activemq.git
Better debug settings for when working /w amqp.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1494217 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
21ddc98591
commit
fec73ddbc1
|
@ -17,6 +17,7 @@
|
|||
package org.apache.activemq.transport.amqp;
|
||||
|
||||
import org.apache.activemq.broker.BrokerService;
|
||||
import org.apache.activemq.store.kahadb.KahaDBStore;
|
||||
// import org.apache.activemq.leveldb.LevelDBStore;
|
||||
|
||||
import java.io.File;
|
||||
|
@ -25,11 +26,11 @@ 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();
|
||||
bs.addConnector("amqp://0.0.0.0:5672?trace=true");
|
||||
KahaDBStore store = new KahaDBStore();
|
||||
store.setDirectory(new File("target/activemq-data/kahadb"));
|
||||
bs.setPersistenceAdapter(store);
|
||||
bs.deleteAllMessages();
|
||||
bs.start();
|
||||
bs.waitUntilStopped();
|
||||
}
|
||||
|
|
|
@ -20,7 +20,7 @@
|
|||
#
|
||||
log4j.rootLogger=WARN, console, file
|
||||
log4j.logger.org.apache.activemq=INFO
|
||||
log4j.logger.org.apache.activemq.transport.amqp=INFO
|
||||
log4j.logger.org.apache.activemq.transport.amqp=TRACE
|
||||
log4j.logger.org.fusesource=INFO
|
||||
|
||||
# Console will only display warnnings
|
||||
|
|
Loading…
Reference in New Issue