Contents

# encoding: utf-8

module Kurchatov
  class Queue
    QUEUE_MAX_SIZE = 300

    def initialize
      @events = ::Queue.new
    end

    def <<(event)
      if @events.size >= QUEUE_MAX_SIZE
        drop = @events.shift
        Log.error("Drop event: #{drop.inspect}. See Kurchatov::Queue::QUEUE_MAX_SIZE")
      end
      @events << event
    end

    def all
      cur_events = Array.new
      until @events.empty?
        cur_events << @events.shift
      end
      cur_events
    end

  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
kurchatov-0.0.4b	lib/kurchatov/queue.rb