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

Update some logging for better coverage

This commit is contained in:
Timothy Bish 2015-04-16 18:46:40 -04:00
parent a5c2f3f423
commit 2013c6a54f
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpReceiver.java
View File

@ -220,7 +220,7 @@ public class AmqpReceiver extends AmqpAbstractReceiver {
delivery.disposition(rejected); delivery.disposition(rejected);
} else { } else {
if (getEndpoint().getCredit() <= (getConfiguredReceiverCredit() * .2)) { if (getEndpoint().getCredit() <= (getConfiguredReceiverCredit() * .2)) {
LOG.trace("Sending more credit ({}) to producer: {}", getConfiguredReceiverCredit() - getEndpoint().getCredit(), getProducerId()); LOG.debug("Sending more credit ({}) to producer: {}", getConfiguredReceiverCredit() - getEndpoint().getCredit(), getProducerId());
getEndpoint().flow(getConfiguredReceiverCredit() - getEndpoint().getCredit()); getEndpoint().flow(getConfiguredReceiverCredit() - getEndpoint().getCredit());
} }
@ -241,7 +241,7 @@ public class AmqpReceiver extends AmqpAbstractReceiver {
}); });
} else { } else {
if (getEndpoint().getCredit() <= (getConfiguredReceiverCredit() * .2)) { if (getEndpoint().getCredit() <= (getConfiguredReceiverCredit() * .2)) {
LOG.trace("Sending more credit ({}) to producer: {}", getConfiguredReceiverCredit() - getEndpoint().getCredit(), getProducerId()); LOG.debug("Sending more credit ({}) to producer: {}", getConfiguredReceiverCredit() - getEndpoint().getCredit(), getProducerId());
getEndpoint().flow(getConfiguredReceiverCredit() - getEndpoint().getCredit()); getEndpoint().flow(getConfiguredReceiverCredit() - getEndpoint().getCredit());
session.pumpProtonToSocket(); session.pumpProtonToSocket();
} }

2
activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpSender.java
View File

@ -397,7 +397,7 @@ public class AmqpSender extends AmqpAbstractLink<Sender> {
final ActiveMQMessage jms = temp; final ActiveMQMessage jms = temp;
if (jms == null) { if (jms == null) {
LOG.info("End of browse signals endpoint drained."); LOG.trace("Sender:[{}] browse done.", getEndpoint().getName());
// It's the end of browse signal in response to a MessagePull // It's the end of browse signal in response to a MessagePull
getEndpoint().drained(); getEndpoint().drained();
draining = false; draining = false;