class LogStash::Inputs::GooglePubSub::MessageReceiver
Public Class Methods
new(&blk)
click to toggle source
# File lib/logstash/inputs/google_pubsub.rb, line 162 def initialize(&blk) @block = blk end
Public Instance Methods
receiveMessage(message, consumer)
click to toggle source
# File lib/logstash/inputs/google_pubsub.rb, line 166 def receiveMessage(message, consumer) @block.call(message) consumer.ack() rescue ArgumentError, java.util.zip.DataFormatException, java.util.zip.ZipException => e consumer.ack() end