[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 8.0.x in repository https://gitbox.apache.org/repos/asf/qpid-broker-j.git commit e04f933c2fe223624b9921d00f11e4e8bb6a74d1 Author: Dedeepya T 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 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-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
[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 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 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-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
