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 <[email protected]> Authored: Mon Apr 13 09:39:05 2015 -0400 Committer: Timothy Bish <[email protected]> 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);
