This is an automated email from the ASF dual-hosted git repository.

orudyy pushed a commit to branch 8.0.x
in repository https://gitbox.apache.org/repos/asf/qpid-broker-j.git

commit 32df27b195cc6398161d82b1398a858e4a8d2045
Author: Alex Rudyy <oru...@apache.org>
AuthorDate: Tue Jun 15 09:20:23 2021 +0100

    QPID-8523:[Broker-J] Set initial-delivery-count in a response attach only 
when role is a sender
---
 .../org/apache/qpid/server/protocol/v1_0/ErrantLinkEndpoint.java     | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git 
a/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/ErrantLinkEndpoint.java
 
b/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/ErrantLinkEndpoint.java
index a12198e..42d756a 100644
--- 
a/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/ErrantLinkEndpoint.java
+++ 
b/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/ErrantLinkEndpoint.java
@@ -90,7 +90,10 @@ public class ErrantLinkEndpoint<S extends BaseSource, T 
extends BaseTarget> impl
         attachToSend.setName(_link.getName());
         attachToSend.setRole(getRole());
         attachToSend.setHandle(getLocalHandle());
-        attachToSend.setInitialDeliveryCount(UnsignedInteger.ZERO);
+        if (getRole() == Role.SENDER)
+        {
+            attachToSend.setInitialDeliveryCount(UnsignedInteger.ZERO);
+        }
         attachToSend.setSource(getSource());
         attachToSend.setTarget(getTarget());
         _session.sendAttach(attachToSend);

---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org
For additional commands, e-mail: commits-h...@qpid.apache.org

Reply via email to