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 supportedFilters = new HashMap(); protonSender.setContext(sender);