#!/usr/bin/env ruby require_relative "../config/environment" Outboxer::Publisher.publish do |message:, logger:| logger.info("[#{message.id}] publishing") HardJob.perform_async({ "message_id" => message.id }) logger.info("[#{message.id}] published") end