lib/google_pubsub_enhancer.rb in google-pubsub-enhancer-0.1.2 vs lib/google_pubsub_enhancer.rb in google-pubsub-enhancer-0.1.3

@@ -33,9 +33,10 @@
   def work(subscription, opts)
     while received_messages = subscription.pull
       break if opts[:shutdown].call || received_messages == nil
       next if received_messages.empty?
       @stack.call({received_messages: received_messages})
+      subscription.acknowledge(received_messages)  
     end
   end
 
   def create_subscription(subscription_short_name)
     Google::Cloud::Pubsub.new.subscription(self.class.name_by('subscriptions', subscription_short_name))