Use quorum queues with size 3

Signed-off-by: Bogdan Dobrelya <[email protected]>
bogdando · Jul 27, 2021 · de0887d · de0887d
1 parent a5e8828
commit de0887d
Showing 1 changed file with 8 additions and 4 deletions.
diff --git a/rabbitmq_ocf_pcmk/src/jepsen/rabbitmq_ocf_pcmk.clj b/rabbitmq_ocf_pcmk/src/jepsen/rabbitmq_ocf_pcmk.clj
@@ -77,9 +77,11 @@
   (with-ch [ch conn]
     ; Initialize queue
     (lq/declare ch queue
-                  {:durable     false
+                  {:durable     true
                    :auto-delete false
-                   :exclusive   false})))
+                   :exclusive   false
+                   :arguments   {"x-queue-type" "quorum"
+                                 "x-quorum-initial-group-size" 3}})))
 
 (defrecord QueueClient [conn]
   client/Client
@@ -177,9 +179,11 @@
                   :automatically-recover false})]
       (with-ch [ch conn]
         (lq/declare ch "jepsen.semaphore"
-                    {:durable false
+                    {:durable true
                      :auto-delete false
-                     :exclusive false})
+                     :exclusive false
+                     :arguments {"x-queue-type" "quorum"
+                                 "x-quorum-initial-group-size" 3}})
 
         ; Enqueue a single message
         (when (compare-and-set! enqueued? false true)