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

https://issues.apache.org/jira/browse/AMQ-6001 

Refill credit at a slightly faster rate.
This commit is contained in:
Timothy Bish 2015-10-06 11:33:26 -04:00
parent dc06c8dc75
commit bbcd938032
1 changed files with 2 additions and 2 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

@ -227,7 +227,7 @@ public class AmqpReceiver extends AmqpAbstractReceiver {
rejected.setError(condition); rejected.setError(condition);
delivery.disposition(rejected); delivery.disposition(rejected);
} else { } else {
if (getEndpoint().getCredit() <= (getConfiguredReceiverCredit() * .2)) { if (getEndpoint().getCredit() <= (getConfiguredReceiverCredit() * .3)) {
LOG.debug("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());
} }
@ -248,7 +248,7 @@ public class AmqpReceiver extends AmqpAbstractReceiver {
} }
}); });
} else { } else {
if (getEndpoint().getCredit() <= (getConfiguredReceiverCredit() * .2)) { if (getEndpoint().getCredit() <= (getConfiguredReceiverCredit() * .3)) {
LOG.debug("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();