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