Sha256: eee8ce1b08ceb707c953020a62b9b90b0f2212f5366fe87781afd66080758fe2
Contents?: true
Size: 1.49 KB
Versions: 12
Compression:
Stored size: 1.49 KB
Contents
# frozen_string_literal: true
module Eventboss
class Runner
extend Logging
class << self
def launch
queues = Eventboss::QueueListener.select(
include: Eventboss.configuration.listeners[:include],
exclude: Eventboss.configuration.listeners[:exclude]
)
client = Eventboss.configuration.sqs_client
config = Eventboss.configuration
Eventboss::Instrumentation.add(queues)
launcher = Launcher.new(queues, client, worker_count: config.concurrency)
self_read = setup_signals([:SIGTERM])
logger.info('Active listeners:')
queues.each { |queue, listener| logger.info("#{queue}: #{listener}") }
Eventboss::DevelopmentMode.setup_infrastructure(queues) if config.development_mode?
begin
launcher.start
handle_signals(self_read, launcher)
rescue Interrupt
launcher.stop
exit 0
end
end
private
def setup_signals(signals)
self_read, self_write = IO.pipe
signals.each do |signal|
trap signal do
self_write.puts signal
end
end
self_read
end
def handle_signals(self_read, launcher)
while readable_io = IO.select([self_read])
signal = readable_io.first[0].gets.strip
logger.info('runner') { "Received #{signal} signal, gracefully shutting down..." }
launcher.stop
exit 0
end
end
end
end
end
Version data entries
12 entries across 12 versions & 1 rubygems