Update tests for RabbitMQ 3.13.0

rabbitmq · Jan 30, 2024 · 489f903 · 489f903
1 parent 66bfb23
commit 489f903
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 8 deletions.
diff --git a/src/test/groovy/com/rabbitmq/http/client/ClientSpec.groovy b/src/test/groovy/com/rabbitmq/http/client/ClientSpec.groovy
@@ -1137,11 +1137,11 @@ class ClientSpec extends Specification {
     given: "vhost / and definition"
     def v = "/"
     def d = new HashMap<String, Object>()
-    d.put("ha-mode", "all")
+    d.put("expires", 30000)
 
     when: "client declares a policy hop.test"
     def s = "hop.test"
-    client.declarePolicy(v, s, new PolicyInfo(".*", 1, null, d))
+    client.declarePolicy(v, s, new PolicyInfo(".*", 1, "queues", d))
 
     and: "client lists policies in vhost /"
     List<PolicyInfo> ps = client.getPolicies(v)
@@ -1152,7 +1152,7 @@ class ClientSpec extends Specification {
     p.vhost == v
     p.name == s
     p.priority == 1
-    p.applyTo == "all"
+    p.applyTo == "queues"
     p.definition == d
 
     cleanup:
@@ -2185,7 +2185,7 @@ class ClientSpec extends Specification {
     def s = "hop.test"
     def d = new HashMap<String, Object>()
     def p = ".*"
-    d.put("ha-mode", "all")
+    d.put("expires", 30000)
     client.declarePolicy(v, s, new PolicyInfo(p, 0, null, d))
 
     when: "client lists policies"
@@ -2207,7 +2207,7 @@ class ClientSpec extends Specification {
     def s = "hop.test"
     def d = new HashMap<String, Object>()
     def p = ".*"
-    d.put("ha-mode", "all")
+    d.put("expires", 30000)
     client.declarePolicy(v, s, new PolicyInfo(p, 0, null, d))
 
     when: "client lists policies"

diff --git a/src/test/groovy/com/rabbitmq/http/client/ReactorNettyClientSpec.groovy b/src/test/groovy/com/rabbitmq/http/client/ReactorNettyClientSpec.groovy
@@ -1062,7 +1062,7 @@ class ReactorNettyClientSpec extends Specification {
         def s = "hop.test"
         def d = new HashMap<String, Object>()
         def p = ".*"
-        d.put("ha-mode", "all")
+        d.put("expires", 30000)
         client.declarePolicy(v, s, new PolicyInfo(p, 0, null, d)).block()
 
         when: "client lists policies"
@@ -1082,7 +1082,7 @@ class ReactorNettyClientSpec extends Specification {
         def s = "hop.test"
         def d = new HashMap<String, Object>()
         def p = ".*"
-        d.put("ha-mode", "all")
+        d.put("expires", 30000)
         client.declarePolicy(v, s, new PolicyInfo(p, 0, null, d)).block()
 
         when: "client lists policies"
@@ -1468,7 +1468,7 @@ class ReactorNettyClientSpec extends Specification {
         given: "vhost / and definition"
         def v = "/"
         def d = new HashMap<String, Object>()
-        d.put("ha-mode", "all")
+        d.put("expires", 30000)
 
         when: "client declares a policy hop.test"
         def s = "hop.test"