integration_test

gistfile1.txt

# in the test:

queue = TorqueBox::Messaging::Queue.new( '/queue/response' )

queue.receive( :timeout => 120_000 ).should == 'started'
queue.receive( :timeout => 5_000 ).should be_nil

long_running_job.rb

class LongRunningJob

  include TorqueBox::Injectors

  def initialize(opts)
    @options = opts
    @response_queue = inject( '/queue/response' )
  end

  def run()
    $stderr.puts "Job executing! queue is #{@response_queue}"
    @response_queue.publish( 'started' ) 
    sleep( 5 )
    @response_queue.publish( 'done' ) 
  end

end

torquebox.yml

jobs:

  job.four:
    job: LongRunningJob
    description: My long running job has timeout
    cron: "*/1 * * * * ?"
    timeout: 3 s