anicholson · October 27, 2016 23:24 · Oct 27, 2016
diff --git a/delayed_job b/delayed_job
@@ -0,0 +1,38 @@
+#!/usr/bin/env ruby
+# frozen_string_literal: true
+
+require 'bundler/setup'
+require_relative '../config/environment'
+
+require 'rack'
+
+# Take the whole script down if anything goes remotely wrong
+Thread.abort_on_exception = true
+
+MACCHIATO_PORT = 4000
+
+# Health Check: A rack app that listens on 4000
+# and returns 200 to indicate it's alive.
+
+_health_check_thread = Thread.new do
+  headers = { 'Content-Type' => 'text/plain' }.freeze
+  response = ['200', headers, 'Alive'].freeze
+
+  app = proc { |_env| response }
+
+  Rack::Handler::WEBrick.run app, Port: MACCHIATO_PORT
+end
+
+# Worker Job: A thread that initiates the DelayedJob worker queue.
+
+delayed_job_options = {
+  quiet: false
+}.freeze
+
+worker_thread = Thread.new { Delayed::Worker.new(delayed_job_options).start }
+
+# Wait for the worker queue thread to finish before ending the script.
+# If it crashes, the script will end and take the health check thread
+# down as well.
+
+worker_thread.join