Contents

module Chillout
  module Middleware

    class SidekiqCreationsMonitor
      def initialize(options)
        @client = options.fetch(:client)
      end

      def call(_worker, _job, _queue)
        yield
      ensure
        if creations = Chillout.creations
          Chillout.creations = nil
          @client.enqueue(creations)
        end
      end
    end

  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
chillout-0.8.5.1	lib/chillout/middleware/sidekiq.rb
chillout-0.8.6	lib/chillout/middleware/sidekiq.rb
chillout-0.8.5	lib/chillout/middleware/sidekiq.rb
chillout-0.8.4	lib/chillout/middleware/sidekiq.rb