integration_test

long_running_job.rb

class LongRunningJob

  include TorqueBox::Injectors

  def initialize(opts)
    @options = opts
    @polish     = inject( Java::pl.softwaremine.ThingThree )
    @response_queue = inject( '/queue/response' )
    @init_params_queue = inject( '/queue/init_params' )
    @init_params_queue.publish( @options )
  end

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

end

torquebox.yml

jobs:

  job.four:
    job: LongRunningJob
    description: My long running job has timeout
    cron: 01 01 01 15 * ?
    timeout: 500 s