Sha256: 954eb1b79f89950859536dfd05b2a7cdf242ad41edd0d92dbf3a2f74aeda5f91

Contents?: true

Size: 513 Bytes

Versions: 16

Compression:

Stored size: 513 Bytes

Contents

$: << File.expand_path('../lib', File.dirname(__FILE__))
require 'sneakers'

class BenchmarkWorker
  include Sneakers::Worker
  from_queue 'downloads',
             exchange_options: { durable: false },
             queue_options: { durable: false },
             :ack => true,
             :threads => 50,
             :prefetch => 50,
             :timeout_job_after => 1,
             :exchange => 'dummy',
             :heartbeat => 5,
             :amqp_heartbeat => 10
  def work(msg)
    ack!
  end
end



Version data entries

16 entries across 16 versions & 2 rubygems

Version Path
kicks-3.1.1 examples/benchmark_worker.rb
kicks-3.1.0 examples/benchmark_worker.rb
kicks-3.0.0 examples/benchmark_worker.rb
kicks-3.0.0.pre examples/benchmark_worker.rb
sneakers-2.12.0 examples/benchmark_worker.rb
sneakers-2.12.0.rc1 examples/benchmark_worker.rb
sneakers-2.11.0 examples/benchmark_worker.rb
sneakers-2.7.0 examples/benchmark_worker.rb
sneakers-2.6.0 examples/benchmark_worker.rb
sneakers-2.5.0 examples/benchmark_worker.rb
sneakers-2.4.0 examples/benchmark_worker.rb
sneakers-2.3.5 examples/benchmark_worker.rb
sneakers-2.3.4 examples/benchmark_worker.rb
sneakers-2.3.2 examples/benchmark_worker.rb
sneakers-2.3.1 examples/benchmark_worker.rb
sneakers-2.3.0 examples/benchmark_worker.rb