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

Inherits:
Object
  • Object
show all
Defined in:
lib/logstash/util/wrapped_synchronous_queue.rb

Instance Method Summary collapse

Constructor Details

#initialize(queue) ⇒ WriteClient

Returns a new instance of WriteClient.



161
162
163
 
# File 'lib/logstash/util/wrapped_synchronous_queue.rb', line 161

def initialize(queue)
  @queue = queue
end

Instance Method Details

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



165
166
167
 
# File 'lib/logstash/util/wrapped_synchronous_queue.rb', line 165

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

#push_batch(batch) ⇒ Object 



170
171
172
 
# File 'lib/logstash/util/wrapped_synchronous_queue.rb', line 170

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