You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ta...@apache.org on 2015/10/01 01:21:57 UTC
qpid-jms git commit: NO-JIRA Send back credit a bit faster to avoid
tripping some slow consumer warnings on some brokers.
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 <ta...@gmail.com>
Authored: Wed Sep 30 19:21:47 2015 -0400
Committer: Timothy Bish <ta...@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-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org