lib/pwwka/receiver.rb in pwwka-0.4.0 vs lib/pwwka/receiver.rb in pwwka-0.4.1

@@ -20,10 +20,10 @@
     def self.subscribe(handler_klass, queue_name, routing_key: "#.#", block: true)
       raise "#{handler_klass.name} must respond to `handle!`" unless handler_klass.respond_to?(:handle!)
       receiver  = new(queue_name, routing_key)
       begin
         info "Receiving on #{queue_name}"
-        receiver.topic_queue.subscribe(ack: true, block: block) do |delivery_info, properties, payload|
+        receiver.topic_queue.subscribe(manual_ack: true, block: block) do |delivery_info, properties, payload|
           begin
             payload = ActiveSupport::HashWithIndifferentAccess.new(JSON.parse(payload))
             handler_klass.handle!(delivery_info, properties, payload)
             receiver.ack(delivery_info.delivery_tag)
             info "Processed Message on #{queue_name} -> #{payload}, #{delivery_info.routing_key}"