# assumes an environment task that sets up your app environment desc “worker that reads the queue and sends messages through the router as configured” task :superbolt => :environment do
begin Superbolt::App.new(Superbolt.app_name, {}).run do |message, logger| Superbolt::Router.new(message, logger).perform end # Rescue SignalException so that we don't spam error handlers like Airbrake # with SIGTERM errors every time a task is killed (machine restarts, etc.) rescue SignalException => e Rails.logger.info(e.message) end
end