You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by or...@apache.org on 2021/05/18 08:12:43 UTC
[qpid-broker-j] branch main updated: QPID-8518: [Broker-J] Message
transfer freezes when session runs out of transfer frames
This is an automated email from the ASF dual-hosted git repository.
orudyy pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/qpid-broker-j.git
The following commit(s) were added to refs/heads/main by this push:
new 312cec0 QPID-8518: [Broker-J] Message transfer freezes when session runs out of transfer frames
312cec0 is described below
commit 312cec0b6dda75b0501efd50cd74178fb6a29960
Author: Marek Laca <mk...@gmail.com>
AuthorDate: Fri Apr 16 10:39:53 2021 +0200
QPID-8518: [Broker-J] Message transfer freezes when session runs out of transfer frames
This closes #83
---
.../java/org/apache/qpid/server/protocol/v1_0/AMQPConnection_1_0.java | 2 +-
.../qpid/server/protocol/v1_0/AbstractReceivingLinkEndpoint.java | 4 ++++
2 files changed, 5 insertions(+), 1 deletion(-)
diff --git a/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/AMQPConnection_1_0.java b/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/AMQPConnection_1_0.java
index 665ee0a..10a907d 100644
--- a/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/AMQPConnection_1_0.java
+++ b/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/AMQPConnection_1_0.java
@@ -44,7 +44,7 @@ public interface AMQPConnection_1_0<C extends AMQPConnection_1_0<C>> extends AMQ
String CONNECTION_SESSION_CREDIT_WINDOW_SIZE = "connection.sessionCreditWindowSize";
@ManagedContextDefault(name = CONNECTION_SESSION_CREDIT_WINDOW_SIZE)
- int DEFAULT_CONNECTION_SESSION_CREDIT_WINDOW_SIZE = 8192;
+ int DEFAULT_CONNECTION_SESSION_CREDIT_WINDOW_SIZE = 2 * 8192;
String SEND_SASL_FINAL_CHALLENGE_AS_CHALLENGE = "connection.sendSaslFinalResponseAsChallenge";
@ManagedContextDefault(name = SEND_SASL_FINAL_CHALLENGE_AS_CHALLENGE)
diff --git a/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/AbstractReceivingLinkEndpoint.java b/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/AbstractReceivingLinkEndpoint.java
index f346dbe..86fda5b 100644
--- a/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/AbstractReceivingLinkEndpoint.java
+++ b/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/AbstractReceivingLinkEndpoint.java
@@ -173,6 +173,10 @@ public abstract class AbstractReceivingLinkEndpoint<T extends BaseTarget> extend
_currentDelivery = null;
}
}
+ else
+ {
+ getSession().sendFlowConditional();
+ }
}
else
{
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org