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