Class: LogStash::Inputs::Logstash::QueueWrapper

Inherits:

Object

• Object
• LogStash::Inputs::Logstash::QueueWrapper

Defined in:

lib/logstash/inputs/logstash.rb

Instance Method Summary

• #<<(event) ⇒ Object
• #initialize(wrapped_queue, decorator) ⇒ QueueWrapper constructor

  A new instance of QueueWrapper.

Constructor Details

#initialize(wrapped_queue, decorator) ⇒ QueueWrapper

Returns a new instance of QueueWrapper.

# File 'lib/logstash/inputs/logstash.rb', line 176

def initialize(wrapped_queue, decorator)
  @wrapped_queue = wrapped_queue
  @decorator = decorator
end

Instance Method Details

#<<(event) ⇒ Object

# File 'lib/logstash/inputs/logstash.rb', line 181

def << (event)
  event.remove('[@metadata][void]')
  @decorator.call(event)
  @wrapped_queue << event
end