lib/google_pubsub_enhancer.rb in google-pubsub-enhancer-0.4.0 vs lib/google_pubsub_enhancer.rb in google-pubsub-enhancer-0.4.1

@@ -41,9 +41,10 @@
 
   def work(subscription, opts)
     while received_messages = subscription.pull(:max => GooglePubsubEnhancer::Constants::MAX_PULL_SIZE)
       break if opts[:shutdown].call || received_messages == nil
       next if received_messages.empty?
+      @logger.debug{"#{received_messages.length} messages received"}
       @stack.call({received_messages: received_messages})
       subscription.acknowledge(received_messages)
     end
   end