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/18 19:25:03 UTC
svn commit: r1494217 - in /activemq/trunk/activemq-amqp/src/test:
java/org/apache/activemq/transport/amqp/IDERunner.java
resources/log4j.properties
Author: chirino
Date: Tue Jun 18 17:25:03 2013
New Revision: 1494217
URL: http://svn.apache.org/r1494217
Log:
Better debug settings for when working /w amqp.
Modified:
activemq/trunk/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/IDERunner.java
activemq/trunk/activemq-amqp/src/test/resources/log4j.properties
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=1494217&r1=1494216&r2=1494217&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 Tue Jun 18 17:25:03 2013
@@ -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();
}
Modified: activemq/trunk/activemq-amqp/src/test/resources/log4j.properties
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-amqp/src/test/resources/log4j.properties?rev=1494217&r1=1494216&r2=1494217&view=diff
==============================================================================
--- activemq/trunk/activemq-amqp/src/test/resources/log4j.properties (original)
+++ activemq/trunk/activemq-amqp/src/test/resources/log4j.properties Tue Jun 18 17:25:03 2013
@@ -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