activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject activemq git commit: https://issues.apache.org/jira/browse/AMQ-6001
Date Tue, 06 Oct 2015 15:34:24 GMT
Repository: activemq
Updated Branches:
  refs/heads/activemq-5.12.x 82a2c0553 -> 789419ab9


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

Refill credit at a slightly faster rate.
(cherry picked from commit bbcd93803207f22d6c549bc79dd7d0c28e16be26)


Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/789419ab
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/789419ab
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/789419ab

Branch: refs/heads/activemq-5.12.x
Commit: 789419ab9d87b735688adb5843427fb4deaea590
Parents: 82a2c05
Author: Timothy Bish <tabish121@gmail.com>
Authored: Tue Oct 6 11:33:26 2015 -0400
Committer: Timothy Bish <tabish121@gmail.com>
Committed: Tue Oct 6 11:34:18 2015 -0400

----------------------------------------------------------------------
 .../apache/activemq/transport/amqp/protocol/AmqpReceiver.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq/blob/789419ab/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpReceiver.java
----------------------------------------------------------------------
diff --git a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpReceiver.java
b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpReceiver.java
index e62ad04..b2db298 100644
--- a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpReceiver.java
+++ b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpReceiver.java
@@ -227,7 +227,7 @@ public class AmqpReceiver extends AmqpAbstractReceiver {
                             rejected.setError(condition);
                             delivery.disposition(rejected);
                         } else {
-                            if (getEndpoint().getCredit() <= (getConfiguredReceiverCredit()
* .2)) {
+                            if (getEndpoint().getCredit() <= (getConfiguredReceiverCredit()
* .3)) {
                                 LOG.debug("Sending more credit ({}) to producer: {}", getConfiguredReceiverCredit()
- getEndpoint().getCredit(), getProducerId());
                                 getEndpoint().flow(getConfiguredReceiverCredit() - getEndpoint().getCredit());
                             }
@@ -248,7 +248,7 @@ public class AmqpReceiver extends AmqpAbstractReceiver {
                     }
                 });
             } else {
-                if (getEndpoint().getCredit() <= (getConfiguredReceiverCredit() * .2))
{
+                if (getEndpoint().getCredit() <= (getConfiguredReceiverCredit() * .3))
{
                     LOG.debug("Sending more credit ({}) to producer: {}", getConfiguredReceiverCredit()
- getEndpoint().getCredit(), getProducerId());
                     getEndpoint().flow(getConfiguredReceiverCredit() - getEndpoint().getCredit());
                     session.pumpProtonToSocket();


Mime
View raw message