Contents

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

class WorkflowWorker
  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)
    logger.info("Seriously, i'm DONE.")
    publish "cleaned up", :to_queue => "foobar"
    logger.info("Published to 'foobar'")
    ack!
  end
end

Version data entries

17 entries across 17 versions & 2 rubygems

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