Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

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

This commit is contained in:
Timothy Bish 2015-04-13 09:39:05 -04:00
parent 2562cf21a2
commit f0ebda7ef9
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpSession.java
View File

@ -91,7 +91,7 @@ public class AmqpSession implements AmqpResource {
@Override @Override
public void open() { public void open() {
LOG.trace("Session {} opened", getSessionId()); LOG.debug("Session {} opened", getSessionId());
getEndpoint().setContext(this); getEndpoint().setContext(this);
getEndpoint().setIncomingCapacity(Integer.MAX_VALUE); getEndpoint().setIncomingCapacity(Integer.MAX_VALUE);
@ -102,7 +102,7 @@ public class AmqpSession implements AmqpResource {
@Override @Override
public void close() { public void close() {
LOG.trace("Session {} closed", getSessionId()); LOG.debug("Session {} closed", getSessionId());
getEndpoint().setContext(null); getEndpoint().setContext(null);
getEndpoint().close(); getEndpoint().close();
@ -157,6 +157,8 @@ public class AmqpSession implements AmqpResource {
ProducerInfo producerInfo = new ProducerInfo(getNextProducerId()); ProducerInfo producerInfo = new ProducerInfo(getNextProducerId());
final AmqpReceiver receiver = new AmqpReceiver(this, protonReceiver, producerInfo); final AmqpReceiver receiver = new AmqpReceiver(this, protonReceiver, producerInfo);
LOG.debug("opening new receiver {} on link: {}", producerInfo.getProducerId(), protonReceiver.getName());
try { try {
Target target = (Target) remoteTarget; Target target = (Target) remoteTarget;
ActiveMQDestination destination = null; ActiveMQDestination destination = null;
@ -213,6 +215,8 @@ public class AmqpSession implements AmqpResource {
ConsumerInfo consumerInfo = new ConsumerInfo(getNextConsumerId()); ConsumerInfo consumerInfo = new ConsumerInfo(getNextConsumerId());
final AmqpSender sender = new AmqpSender(this, protonSender, consumerInfo); final AmqpSender sender = new AmqpSender(this, protonSender, consumerInfo);
LOG.debug("opening new sender {} on link: {}", consumerInfo.getConsumerId(), protonSender.getName());
try { try {
final Map<Symbol, Object> supportedFilters = new HashMap<Symbol, Object>(); final Map<Symbol, Object> supportedFilters = new HashMap<Symbol, Object>();
protonSender.setContext(sender); protonSender.setContext(sender);