Contents

module Stackify::Metrics
  class MetricsQueue < SizedQueue
    include MonitorMixin

    def initialize
      super(Stackify.configuration.queue_max_size)
    end

    alias :old_push :push

    def add_metric metric
      self.synchronize do
        self.old_push metric
      end
    end

    alias :old_size :size

    def size
      self.synchronize do
        self.old_size
      end
    end
  end
end

Version data entries

22 entries across 22 versions & 1 rubygems

Version	Path
stackify-api-ruby-1.0.4	lib/stackify/metrics/metrics_queue.rb
stackify-api-ruby-1.0.3	lib/stackify/metrics/metrics_queue.rb