Class: LogStash::Util::WrappedSynchronousQueue::WriteClient

Inherits:

Object

• Object
• LogStash::Util::WrappedSynchronousQueue::WriteClient

Defined in:

lib/logstash/util/wrapped_synchronous_queue.rb

Instance Method Summary

• #initialize(queue) ⇒ WriteClient constructor

  A new instance of WriteClient.

• #push(event) ⇒ Object (also: #<<)
• #push_batch(batch) ⇒ Object

Constructor Details

#initialize(queue) ⇒ WriteClient

# File 'lib/logstash/util/wrapped_synchronous_queue.rb', line 129

def initialize(queue)
  @queue = queue
end

Instance Method Details

#push(event) ⇒ Object Also known as: <<

# File 'lib/logstash/util/wrapped_synchronous_queue.rb', line 133

def push(event)
  @queue.put(event)
end

#push_batch(batch) ⇒ Object

# File 'lib/logstash/util/wrapped_synchronous_queue.rb', line 138

def push_batch(batch)
  LsQueueUtils.addAll(@queue, batch)
end