Fix 'double ack'. (#49)

ideacrew · Jul 11, 2022 · 5112e29 · 5112e29
1 parent 7e85d8d
commit 5112e29
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/app/models/listeners/enrollment_event_batch_handler.rb b/app/models/listeners/enrollment_event_batch_handler.rb
@@ -30,7 +30,6 @@ def create_enrollment_batch(delivery_info, parsed_event, body, event_time)
                                            :event_time => event_time.to_i.to_s
                                        })
       end
-      channel.ack(delivery_info.delivery_tag, false)
     end
     def create_batch_transaction(delivery_info, parsed_event, body, m_headers, event_time)
       EnrollmentEvents::Batch.create_batch_transaction_and_yield(parsed_event, body, m_headers, event_time) do |transaction|
@@ -128,4 +127,4 @@ def self.run
       conn.close
     end
   end
-end
+end