add quorom queue arguments

Author: matt--williams

lib/acapi/amqp/worker_specification.rb

@@ -126,7 +126,8 @@ def execute_sneakers_config_against(kls)
                :heartbeat => 5,
                :retry_max_times => #{retry_count},
                :arguments => {
-                 :'x-dead-letter-exchange' => "#{retry_exchange_name}"
+                 :'x-dead-letter-exchange' => "#{retry_exchange_name}",
+                 :'x-queue-type' => 'quorum'
                }
           })
         RUBYCODE

lib/acapi/local_amqp_publisher.rb

@@ -68,7 +68,7 @@ def open_connection_if_needed
       @connection = Bunny.new
       @connection.start
       @channel = @connection.create_channel
-      @queue = @channel.queue(QUEUE_NAME, {:durable => true})
+      @queue = @channel.queue(QUEUE_NAME, {:durable => true,  :arguments => {'x-queue-type' => 'quorum'}})
       @exchange = @channel.fanout(EXCHANGE_NAME, {:durable => true})
       @queue.bind(@exchange, {})
     end