lib/songkick_queue/worker.rb in songkick_queue-0.1.0 vs lib/songkick_queue/worker.rb in songkick_queue-0.2.0

@@ -63,10 +63,10 @@
     # Declare a queue and subscribe to it
     #
     # @param consumer_class [Class] to subscribe to
     def subscribe_to_queue(consumer_class)
       queue = channel.queue(consumer_class.queue_name, durable: true,
-        arguments: {'x-ha-policy' => 'all'})
+        arguments: { 'x-ha-policy' => 'all' })
 
       queue.subscribe(manual_ack: true) do |delivery_info, properties, payload|
         process_message(consumer_class, delivery_info, properties, payload)
       end