Sha256: f5d9278c1517ad38124b97f914b313db23de4f5532cb7a77950599c7673d5805
Contents?: true
Size: 579 Bytes
Versions: 67
Compression:
Stored size: 579 Bytes
Contents
$:.unshift "lib" require 'backburner' # Define ruby job class TestJob include Backburner::Queue # queue "test-job" def self.perform(value, user) puts "[TestJob] Running perform with args: [#{value}, #{user}]" end end # Configure Backburner Backburner.configure do |config| config.beanstalk_url = "beanstalk://127.0.0.1" config.tube_namespace = "demo.production" end # Enqueue tasks Backburner.enqueue TestJob, 5, 3 Backburner.enqueue TestJob, 10, 6 # Work tasks using threaded worker Backburner.work("test-job", :worker => Backburner::Workers::ThreadsOnFork)
Version data entries
67 entries across 67 versions & 2 rubygems