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/06/15 08:20:42 UTC
[qpid-broker-j] 01/02: QPID-8523:[Broker-J] Set
initial-delivery-count in a response attach when destination is not found
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
commit e561dcdd236e8d30de2e2138831798512776bfce
Author: Dedeepya T <de...@yahoo.co.in>
AuthorDate: Mon Jun 14 18:43:20 2021 +0530
QPID-8523:[Broker-J] Set initial-delivery-count in a response attach when destination is not found
This closes #92
---
.../java/org/apache/qpid/server/protocol/v1_0/ErrantLinkEndpoint.java | 1 +
.../org/apache/qpid/tests/protocol/v1_0/transport/link/AttachTest.java | 1 +
2 files changed, 2 insertions(+)
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 1bd9604..a12198e 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,6 +90,7 @@ public class ErrantLinkEndpoint<S extends BaseSource, T extends BaseTarget> impl
attachToSend.setName(_link.getName());
attachToSend.setRole(getRole());
attachToSend.setHandle(getLocalHandle());
+ attachToSend.setInitialDeliveryCount(UnsignedInteger.ZERO);
attachToSend.setSource(getSource());
attachToSend.setTarget(getTarget());
_session.sendAttach(attachToSend);
diff --git a/systests/protocol-tests-amqp-1-0/src/test/java/org/apache/qpid/tests/protocol/v1_0/transport/link/AttachTest.java b/systests/protocol-tests-amqp-1-0/src/test/java/org/apache/qpid/tests/protocol/v1_0/transport/link/AttachTest.java
index cac9ecd..5aa0b37 100644
--- a/systests/protocol-tests-amqp-1-0/src/test/java/org/apache/qpid/tests/protocol/v1_0/transport/link/AttachTest.java
+++ b/systests/protocol-tests-amqp-1-0/src/test/java/org/apache/qpid/tests/protocol/v1_0/transport/link/AttachTest.java
@@ -150,6 +150,7 @@ public class AttachTest extends BrokerAdminUsingTestBase
assertThat(responseAttach.getName(), is(notNullValue()));
assertThat(responseAttach.getHandle().longValue(), is(both(greaterThanOrEqualTo(0L)).and(lessThan(UnsignedInteger.MAX_VALUE.longValue()))));
assertThat(responseAttach.getRole(), is(Role.SENDER));
+ assertThat(responseAttach.getInitialDeliveryCount(), is((UnsignedInteger.ZERO)));
assertThat(responseAttach.getSource(), is(nullValue()));
assertThat(responseAttach.getTarget(), is(nullValue()));
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org