Contents

#!/usr/bin/env ruby

require_relative "../config/environment"

Outboxer::Publisher.publish do |args|
  logger = args.logger
  message = args.message

  logger.info("[#{message.id}] publishing")
  HardJob.perform_async({ "message_id" => message.id })
  logger.info("[#{message.id}] published")
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
outboxer-0.1.9	generators/outboxer/templates/bin/publisher.rb
outboxer-0.1.8	generators/outboxer/templates/bin/publisher.rb
outboxer-0.1.6	generators/outboxer/templates/bin/publisher.rb
outboxer-0.1.5	generators/outboxer/templates/bin/publisher.rb