Sha256: e912544810fbf05dce5952bf3aea0115c100dff3dcc6e7802402edbab1326cd0

Contents?: true

Size: 464 Bytes

Versions: 16

Compression:

Stored size: 464 Bytes

Contents

module Rollbar
  module Delay
    class GirlFriday

      class << self
        attr_accessor :queue

        def call(payload)
          new.call(payload)
        end
      end

      def queue_class
        ::GirlFriday::WorkQueue
      end

      def call(payload)
        self.class.queue = queue_class.new(nil, :size => 5) do |payload|
          Rollbar.process_payload(payload)
        end

        self.class.queue.push(payload)
      end
    end
  end
end

Version data entries

16 entries across 16 versions & 1 rubygems

Version Path
rollbar-1.3.0 lib/rollbar/delay/girl_friday.rb
rollbar-1.2.13 lib/rollbar/delay/girl_friday.rb
rollbar-1.2.12 lib/rollbar/delay/girl_friday.rb
rollbar-1.2.11 lib/rollbar/delay/girl_friday.rb
rollbar-1.2.10 lib/rollbar/delay/girl_friday.rb
rollbar-1.2.9 lib/rollbar/delay/girl_friday.rb
rollbar-1.2.8 lib/rollbar/delay/girl_friday.rb
rollbar-1.2.7 lib/rollbar/delay/girl_friday.rb
rollbar-1.2.6 lib/rollbar/delay/girl_friday.rb
rollbar-1.2.5 lib/rollbar/delay/girl_friday.rb
rollbar-1.2.4 lib/rollbar/delay/girl_friday.rb
rollbar-1.2.3 lib/rollbar/delay/girl_friday.rb
rollbar-1.2.2 lib/rollbar/delay/girl_friday.rb
rollbar-1.2.1 lib/rollbar/delay/girl_friday.rb
rollbar-1.2.0 lib/rollbar/delay/girl_friday.rb
rollbar-1.1.0 lib/rollbar/delay/girl_friday.rb