You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2014/01/29 20:58:45 UTC
[1/2] git commit: Add some additional logs
Updated Branches:
refs/heads/trunk 8b993b4dc -> 2f9c43f11
Add some additional logs
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/19344991
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/19344991
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/19344991
Branch: refs/heads/trunk
Commit: 19344991af148ea46ef0492c1f9561a93f610448
Parents: 8b993b4
Author: Timothy Bish <ta...@gmai.com>
Authored: Wed Jan 29 12:41:43 2014 -0500
Committer: Timothy Bish <ta...@gmai.com>
Committed: Wed Jan 29 12:41:43 2014 -0500
----------------------------------------------------------------------
.../org/apache/activemq/transport/amqp/AmqpProtocolConverter.java | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq/blob/19344991/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java
----------------------------------------------------------------------
diff --git a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java
index 78ee912..1e43cba 100644
--- a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java
+++ b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java
@@ -371,6 +371,9 @@ class AmqpProtocolConverter implements IAmqpProtocolConverter {
LOG.trace("Dispatching End of Browse Command to consumer {}", md.getConsumerId());
}
consumerContext.onMessageDispatch(md);
+ if (md.getMessage() != null) {
+ LOG.trace("Finished Dispatch of MessageId: {} to consumer", md.getMessage().getMessageId());
+ }
}
} else if (command.getDataStructureType() == ConnectionError.DATA_STRUCTURE_TYPE) {
// Pass down any unexpected async errors. Should this close the connection?
[2/2] git commit: don't trace frames
Posted by ta...@apache.org.
don't trace frames
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/2f9c43f1
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/2f9c43f1
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/2f9c43f1
Branch: refs/heads/trunk
Commit: 2f9c43f11fe0fed5939512c48e611e6ae0b117b6
Parents: 1934499
Author: Timothy Bish <ta...@gmai.com>
Authored: Wed Jan 29 14:39:10 2014 -0500
Committer: Timothy Bish <ta...@gmai.com>
Committed: Wed Jan 29 14:39:10 2014 -0500
----------------------------------------------------------------------
activemq-amqp/src/test/resources/log4j.properties | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq/blob/2f9c43f1/activemq-amqp/src/test/resources/log4j.properties
----------------------------------------------------------------------
diff --git a/activemq-amqp/src/test/resources/log4j.properties b/activemq-amqp/src/test/resources/log4j.properties
index 106fd99..21dcbf4 100755
--- a/activemq-amqp/src/test/resources/log4j.properties
+++ b/activemq-amqp/src/test/resources/log4j.properties
@@ -21,7 +21,7 @@
log4j.rootLogger=WARN, console, file
log4j.logger.org.apache.activemq=INFO
log4j.logger.org.apache.activemq.transport.amqp=TRACE
-log4j.logger.org.apache.activemq.transport.amqp.FRAMES=TRACE
+log4j.logger.org.apache.activemq.transport.amqp.FRAMES=DEBUG
log4j.logger.org.fusesource=INFO
# Console will only display warnnings