Class: LogStash::Util::WrappedAckedQueue::WriteClient

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

Instance Method Summary collapse

Constructor Details

#initialize(queue) ⇒ WriteClient

Returns a new instance of WriteClient.



285
286
287
 
# File 'lib/logstash/util/wrapped_acked_queue.rb', line 285

def initialize(queue)
  @queue = queue
end

Instance Method Details

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



289
290
291
292
293
294
 
# File 'lib/logstash/util/wrapped_acked_queue.rb', line 289

def push(event)
  if @queue.closed?
    raise QueueClosedError.new("Attempted to write an event to a closed AckedQueue")
  end
  @queue.push(event)
end

#push_batch(batch) ⇒ Object 



297
298
299
300
301
302
303
304
 
# File 'lib/logstash/util/wrapped_acked_queue.rb', line 297

def push_batch(batch)
  if @queue.closed?
    raise QueueClosedError.new("Attempted to write a batch to a closed AckedQueue")
  end
  batch.each do |event|
    push(event)
  end
end