activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject activemq git commit: Add a bit of logging for link and session level events.
Date Mon, 13 Apr 2015 13:40:00 GMT
Repository: activemq
Updated Branches:
  refs/heads/master 2562cf21a -> f0ebda7ef


Add a bit of logging for link and session level events.  

Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/f0ebda7e
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/f0ebda7e
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/f0ebda7e

Branch: refs/heads/master
Commit: f0ebda7ef97b0f71ece0a703a86454811f04c865
Parents: 2562cf2
Author: Timothy Bish <tabish121@gmail.com>
Authored: Mon Apr 13 09:39:05 2015 -0400
Committer: Timothy Bish <tabish121@gmail.com>
Committed: Mon Apr 13 09:39:05 2015 -0400

----------------------------------------------------------------------
 .../apache/activemq/transport/amqp/protocol/AmqpSession.java | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq/blob/f0ebda7e/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpSession.java
----------------------------------------------------------------------
diff --git a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpSession.java
b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpSession.java
index 068a170..6ca4d71 100644
--- a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpSession.java
+++ b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpSession.java
@@ -91,7 +91,7 @@ public class AmqpSession implements AmqpResource {
 
     @Override
     public void open() {
-        LOG.trace("Session {} opened", getSessionId());
+        LOG.debug("Session {} opened", getSessionId());
 
         getEndpoint().setContext(this);
         getEndpoint().setIncomingCapacity(Integer.MAX_VALUE);
@@ -102,7 +102,7 @@ public class AmqpSession implements AmqpResource {
 
     @Override
     public void close() {
-        LOG.trace("Session {} closed", getSessionId());
+        LOG.debug("Session {} closed", getSessionId());
 
         getEndpoint().setContext(null);
         getEndpoint().close();
@@ -157,6 +157,8 @@ public class AmqpSession implements AmqpResource {
         ProducerInfo producerInfo = new ProducerInfo(getNextProducerId());
         final AmqpReceiver receiver = new AmqpReceiver(this, protonReceiver, producerInfo);
 
+        LOG.debug("opening new receiver {} on link: {}", producerInfo.getProducerId(), protonReceiver.getName());
+
         try {
             Target target = (Target) remoteTarget;
             ActiveMQDestination destination = null;
@@ -213,6 +215,8 @@ public class AmqpSession implements AmqpResource {
         ConsumerInfo consumerInfo = new ConsumerInfo(getNextConsumerId());
         final AmqpSender sender = new AmqpSender(this, protonSender, consumerInfo);
 
+        LOG.debug("opening new sender {} on link: {}", consumerInfo.getConsumerId(), protonSender.getName());
+
         try {
             final Map<Symbol, Object> supportedFilters = new HashMap<Symbol, Object>();
             protonSender.setContext(sender);


Mime
View raw message