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()
end