class LogStash::Inputs::GooglePubSub::SubscriberListener

Public Class Methods

new(&blk) click to toggle source
# File lib/logstash/inputs/google_pubsub.rb, line 174
def initialize(&blk)
  @block = blk
end

Public Instance Methods

failed(from, failure) click to toggle source
# File lib/logstash/inputs/google_pubsub.rb, line 178
def failed(from, failure)
  @block.call(from, failure)
end