worker.rb
No OneTemporary
Actions

Subscribers

None

File Metadata

	require 'singleton'

	module Bean
	class Worker
	include Singleton

	TIMEOUT = 5

	attr_accessor :job

	# Start consuming jobs.
	def self.work
	instance.work
	end

	# Start consuming jobs.
	#
	# Handles reconnects.
	def work
	register_signals
	watch
	rescue Beaneater::NotConnected
	WebDNS.bean.reconnect!
	end

	# Graceful stop the worker.
	#
	# If no job is running stops immediately.
	def stop
	if job.nil?
	exit
	else
	@stop = true
	end
	end

	private

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

	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 = WebDNS.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