lib/google_pubsub_enhancer.rb in google-pubsub-enhancer-0.5.1 vs lib/google_pubsub_enhancer.rb in google-pubsub-enhancer-0.5.2
- old
+ new
@@ -45,10 +45,9 @@
break if opts[:shutdown].call || received_messages == nil
next if received_messages.empty?
@logger.debug{"#{received_messages.length} messages received"}
env = {received_messages: received_messages, nacked_messages: []}
@stack.call(env)
- p env
subscription.acknowledge(env[:received_messages] - env[:nacked_messages])
end
end
def create_subscription(subscription_short_name)