Class: LogStash::Inputs::ElasticServerlessForwarder::QueueWrapper

Inherits:

Object

• Object
• LogStash::Inputs::ElasticServerlessForwarder::QueueWrapper

Defined in:

lib/logstash/inputs/elastic_serverless_forwarder.rb

Instance Method Summary

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

  A new instance of QueueWrapper.

Constructor Details

#initialize(wrapped_queue) ⇒ QueueWrapper

Returns a new instance of QueueWrapper.

# File 'lib/logstash/inputs/elastic_serverless_forwarder.rb', line 165

def initialize(wrapped_queue)
  @wrapped_queue = wrapped_queue
end

Instance Method Details

#<<(event) ⇒ Object

# File 'lib/logstash/inputs/elastic_serverless_forwarder.rb', line 169

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