Test link refusal on 4.2+

Author: acogoluegnes

.github/workflows/test-pr.yml

@@ -23,8 +23,6 @@ jobs:
           cache: 'maven'
       - name: Start broker
         run: ci/start-broker.sh
-        env:
-          RABBITMQ_IMAGE: pivotalrabbitmq/rabbitmq:pr-14389-otp28
       - name: Start toxiproxy
         run: ci/start-toxiproxy.sh
       - name: Display Java version

src/test/java/com/rabbitmq/client/amqp/impl/ClientTest.java

@@ -19,6 +19,7 @@
 
 import static com.rabbitmq.client.amqp.Management.ExchangeType.FANOUT;
 import static com.rabbitmq.client.amqp.impl.TestConditions.BrokerVersion.RABBITMQ_4_1_0;
+import static com.rabbitmq.client.amqp.impl.TestConditions.BrokerVersion.RABBITMQ_4_2_0;
 import static com.rabbitmq.client.amqp.impl.TestUtils.*;
 import static java.nio.charset.StandardCharsets.*;
 import static java.util.concurrent.TimeUnit.SECONDS;
@@ -426,6 +427,7 @@ void dynamicReceiver() throws Exception {
   }
 
   @Test
+  @BrokerVersionAtLeast(RABBITMQ_4_2_0)
   void refuseLinkSenderToMissingExchangeShouldReturnNotFound() throws Exception {
     try (Client client = client()) {
       org.apache.qpid.protonj2.client.Connection c = connection(client);
@@ -440,6 +442,7 @@ void refuseLinkSenderToMissingExchangeShouldReturnNotFound() throws Exception {
   }
 
   @Test
+  @BrokerVersionAtLeast(RABBITMQ_4_2_0)
   void refuseLinkSenderToInvalidAddressShouldReturnInvalidField() throws Exception {
     try (Client client = client()) {
       org.apache.qpid.protonj2.client.Connection c = connection(client);
@@ -453,6 +456,7 @@ void refuseLinkSenderToInvalidAddressShouldReturnInvalidField() throws Exception
   }
 
   @Test
+  @BrokerVersionAtLeast(RABBITMQ_4_2_0)
   void refuseLinkReceiverToMissingQueueShouldReturnNotFound() throws Exception {
     try (Client client = client()) {
       org.apache.qpid.protonj2.client.Connection c = connection(client);
@@ -470,6 +474,7 @@ void refuseLinkReceiverToMissingQueueShouldReturnNotFound() throws Exception {
   }
 
   @Test
+  @BrokerVersionAtLeast(RABBITMQ_4_2_0)
   void refuseLinkReceiverToInvalidAddressShouldReturnInvalidField() throws Exception {
     try (Client client = client()) {
       org.apache.qpid.protonj2.client.Connection c = connection(client);