From f0ebda7ef97b0f71ece0a703a86454811f04c865 Mon Sep 17 00:00:00 2001
From: Timothy Bish <tabish121@gmail.com>
Date: Mon, 13 Apr 2015 09:39:05 -0400
Subject: [PATCH] Add a bit of logging for link and session level events.

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

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 068a170203..6ca4d71c18 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);