Merge pull request #397 from rabbitmq/sac-support

Convert x-single-active-consumer to a bool
rabbitmq · Oct 1, 2022 · 10942f4 · 10942f4
2 parents 0f665df + 3b21a9e
commit 10942f4
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/main/java/com/rabbitmq/perf/PerfTest.java b/src/main/java/com/rabbitmq/perf/PerfTest.java
@@ -785,6 +785,9 @@ static Map<String, Object> convertKeyValuePairs(String arg) {
         }).map(keyValue -> {
             if ("x-dead-letter-exchange".equals(keyValue[0]) && "amq.default".equals(keyValue[1])) {
                 return new String[] {"x-dead-letter-exchange", ""};
+            }
+            else if ("x-single-active-consumer".equals(keyValue[0])) {
+                return new Object[] {"x-single-active-consumer", Boolean.parseBoolean(String.valueOf(keyValue[1]))};
             } else {
                 return keyValue;
             }