Repository: qpid-jms Updated Branches: refs/heads/master 03d4885db -> d0e5ae1ab
NO-JIRA Send back credit a bit faster to avoid tripping some slow consumer warnings on some brokers. Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/d0e5ae1a Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/d0e5ae1a Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/d0e5ae1a Branch: refs/heads/master Commit: d0e5ae1abcba26b835695a93a1fcc9931041e3b8 Parents: 03d4885 Author: Timothy Bish <tabish...@gmail.com> Authored: Wed Sep 30 19:21:47 2015 -0400 Committer: Timothy Bish <tabish...@gmail.com> Committed: Wed Sep 30 19:21:47 2015 -0400 ---------------------------------------------------------------------- .../main/java/org/apache/qpid/jms/provider/amqp/AmqpConsumer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/d0e5ae1a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpConsumer.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpConsumer.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpConsumer.java index 9b28cd8..69ffcdf 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpConsumer.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpConsumer.java @@ -253,7 +253,7 @@ public class AmqpConsumer extends AmqpAbstractResource<JmsConsumerInfo, Receiver } int currentCredit = getEndpoint().getCredit(); - if (currentCredit <= getResourceInfo().getPrefetchSize() * 0.2) { + if (currentCredit <= getResourceInfo().getPrefetchSize() * 0.3) { int newCredit = getResourceInfo().getPrefetchSize() - currentCredit; LOG.trace("Consumer {} granting additional credit: {}", getConsumerId(), newCredit); getEndpoint().flow(newCredit); --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
