worker.rb
No OneTemporary
Actions

Subscribers

None

File Metadata

	require 'singleton'

	module Bean
	class Worker
	include Singleton

	TIMEOUT = 5

	attr_accessor :job

	def self.work
	instance.work
	end

	def work
	register_signals
	watch
	rescue Beaneater::NotConnected
	Base.beanstalk_reconnect!
	end

	def stop
	if job.nil?
	exit
	else
	@stop = true
	end
	end

	def stop? # rubocop:disable Style/TrivialAccessors
	@stop
	end

	private

	def register_signals
	trap('INT') { stop }
	trap('TERM') { stop }
	end

	def watch
	loop do
	procline('watching')
	break if stop?

	process_job
	end
	rescue Beaneater::TimedOutError
	retry
	end

	def process_job
	self.job = Base.bean.reserve(TIMEOUT)
	log_job

	job.delete
	ensure
	self.job = nil
	end

	def log_job
	procline("working on jobid=#{job.id} #{job.body}")
	Rails.logger.warn(job_id: job.id, job_body: job.body.to_s)
	end

	def procline(line)
	$0 = "bean-#{line}"
	end
	end
	end