Class: LogStash::Inputs::GooglePubSub::MessageReceiver

Inherits:

Object

Object
LogStash::Inputs::GooglePubSub::MessageReceiver

Defined in:: lib/logstash/inputs/google_pubsub.rb

Instance Method Summary collapse

#initialize(&blk) ⇒ MessageReceiver constructor

A new instance of MessageReceiver.
#receiveMessage(message, consumer) ⇒ Object

Constructor Details

#initialize(&blk) ⇒ `MessageReceiver`

Returns a new instance of MessageReceiver.



162
163
164

# File 'lib/logstash/inputs/google_pubsub.rb', line 162

def initialize(&blk)
  @block = blk
end

Instance Method Details

#receiveMessage(message, consumer) ⇒ `Object`

# File 'lib/logstash/inputs/google_pubsub.rb', line 166

def receiveMessage(message, consumer)
  @block.call(message)
  consumer.ack()
end