Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

NO-JIRA Fix test failed due to missing expectation 

Test should add an optional expect close as it is very occasionally able
to hit the wire and the test peer will fail if not expecting it might be.
This commit is contained in:
Timothy Bish 2024-05-31 16:06:57 -04:00
parent fa1c5c7173
commit 0650713b3e
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/connect/AMQPMirrorConnectionTest.java
View File

@ -18,6 +18,7 @@
package org.apache.activemq.artemis.tests.integration.amqp.connect;
import static org.apache.activemq.artemis.protocol.amqp.proton.AMQPTunneledMessageConstants.AMQP_TUNNELED_CORE_MESSAGE_FORMAT;
import static org.apache.activemq.artemis.protocol.amqp.proton.AmqpSupport.CONNECTION_FORCED;
import static org.apache.activemq.artemis.protocol.amqp.proton.AmqpSupport.TUNNEL_CORE_MESSAGES;
import java.lang.invoke.MethodHandles;
@ -152,7 +153,9 @@ public class AMQPMirrorConnectionTest extends AmqpClientTestSupport {
peer.expectAttach().ofSender()
.withName(Matchers.startsWith("$ACTIVEMQ_ARTEMIS_MIRROR"))
.withDesiredCapabilities("amq.mirror", AmqpSupport.CORE_MESSAGE_TUNNELING_SUPPORT.toString())
.respond();
.respond(); // Response omits "amq.mirror" in offered capabilities.
peer.expectClose().withError(CONNECTION_FORCED.toString()).optional(); // Can hit the wire in rare instances.
peer.expectConnectionToDrop();
peer.start();
final URI remoteURI = peer.getServerURI();