Sha256: 603793d4afe1d9fc11a2fc649b9a296a5c7e1e08e4443851aeede2f8e3076aac
Contents?: true
Size: 765 Bytes
Versions: 8
Compression:
Stored size: 765 Bytes
Contents
module Writefully module Workers class Journalist < BaseWorker def publish Writefully.logger.info "Publishing #{message[:resource]} #{message[:slug]}" pencil = Tools::Pencil.new_link(message) pencil.perform end def remove eraser = Tools::Eraser.new_link(message) unless eraser.directory_exists? Writefully.logger.info "Removing #{message[:resource]} #{message[:slug]}" eraser.perform else eraser.terminate end end def message_with_tries message.merge({ tries: (message[:tries] || 1) + 1, run: false }) end def on_death actor, reason Writefully.add_job :journalists, message_with_tries end end end end
Version data entries
8 entries across 8 versions & 1 rubygems