From 7e92c2df240f326c4afff3eb803cf1efeda65f9f Mon Sep 17 00:00:00 2001
From: David Ansari <david.ansari@gmx.de>
Date: Sun, 27 Feb 2022 15:19:59 +0100
Subject: [PATCH] Add tests for any-with-x and all-with-x

for x-match binding argument in headers exchange
---
 .../functional/HeadersExchangeValidation.java |  6 +++
 .../client/test/functional/Routing.java       | 45 +++++++++++++++++++
 2 files changed, 51 insertions(+)

diff --git a/src/test/java/com/rabbitmq/client/test/functional/HeadersExchangeValidation.java b/src/test/java/com/rabbitmq/client/test/functional/HeadersExchangeValidation.java
index b2eeee7719..e62dd04d0b 100644
--- a/src/test/java/com/rabbitmq/client/test/functional/HeadersExchangeValidation.java
+++ b/src/test/java/com/rabbitmq/client/test/functional/HeadersExchangeValidation.java
@@ -47,6 +47,12 @@ public class HeadersExchangeValidation extends BrokerTestCase {
 
         arguments.put("x-match", "any");
         succeedBind(queue, arguments);
+
+        arguments.put("x-match", "all-with-x");
+        succeedBind(queue, arguments);
+
+        arguments.put("x-match", "any-with-x");
+        succeedBind(queue, arguments);
     }
 
     private void failBind(String queue, HashMap<String, Object> arguments) {
diff --git a/src/test/java/com/rabbitmq/client/test/functional/Routing.java b/src/test/java/com/rabbitmq/client/test/functional/Routing.java
index 050eb379b0..45161acddc 100644
--- a/src/test/java/com/rabbitmq/client/test/functional/Routing.java
+++ b/src/test/java/com/rabbitmq/client/test/functional/Routing.java
@@ -170,6 +170,7 @@ private void checkGet(String queue, boolean messageExpected)
         spec.put("h1", "12345");
         spec.put("h2", "bar");
         spec.put("h3", null);
+        spec.put("x-key-1", "bindings starting with x- get filtered out");
         spec.put("x-match", "all");
         channel.queueBind(Q1, "amq.match", "", spec);
         spec.put("x-match", "any");
@@ -226,6 +227,10 @@ private void checkGet(String queue, boolean messageExpected)
         map.put("h2", "quux");
         channel.basicPublish("amq.match", "", props.build(), "8".getBytes());
 
+        map.clear();
+        map.put("x-key-1", "bindings starting with x- get filtered out");
+        channel.basicPublish("amq.match", "", props.build(), "9".getBytes());
+
         checkGet(Q1, true); // 4
         checkGet(Q1, false);
 
@@ -240,6 +245,46 @@ private void checkGet(String queue, boolean messageExpected)
         checkGet(Q2, false);
     }
 
+    @Test public void headersWithXRouting() throws Exception {
+        Map<String, Object> spec = new HashMap<String, Object>();
+        spec.put("x-key-1", "value-1");
+        spec.put("x-key-2", "value-2");
+        spec.put("x-match", "all-with-x");
+        channel.queueBind(Q1, "amq.match", "", spec);
+        spec.put("x-match", "any-with-x");
+        channel.queueBind(Q2, "amq.match", "", spec);
+
+        AMQP.BasicProperties.Builder props = new AMQP.BasicProperties.Builder();
+        channel.basicPublish("amq.match", "", props.build(), "0".getBytes());
+
+        Map<String, Object> map = new HashMap<String, Object>();
+        props.headers(map);
+
+        map.clear();
+        map.put("x-key-1", "value-1");
+        channel.basicPublish("amq.match", "", props.build(), "1".getBytes());
+
+        map.clear();
+        map.put("x-key-1", "value-1");
+        map.put("x-key-2", "value-2");
+        channel.basicPublish("amq.match", "", props.build(), "2".getBytes());
+
+        map.clear();
+        map.put("x-key-1", "value-1");
+        map.put("x-key-2", "value-2");
+        map.put("x-key-3", "value-3");
+        channel.basicPublish("amq.match", "", props.build(), "3".getBytes());
+
+        checkGet(Q1, true); // 2
+        checkGet(Q1, true); // 3
+        checkGet(Q1, false);
+
+        checkGet(Q2, true); // 1
+        checkGet(Q2, true); // 2
+        checkGet(Q2, true); // 3
+        checkGet(Q2, false);
+    }
+
     @Test public void basicReturn() throws IOException {
         channel.addReturnListener(makeReturnListener());
         returnCell = new BlockingCell<Integer>();