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
        Writefully.logger.info "Removing #{message[:resource]} #{message[:slug]}"
      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

9 entries across 9 versions & 1 rubygems

Version	Path
writefully-0.4.10	lib/writefully/workers/journalist.rb
writefully-0.4.8	lib/writefully/workers/journalist.rb
writefully-0.4.7	lib/writefully/workers/journalist.rb
writefully-0.4.6	lib/writefully/workers/journalist.rb
writefully-0.4.5	lib/writefully/workers/journalist.rb
writefully-0.4.4	lib/writefully/workers/journalist.rb
writefully-0.4.2	lib/writefully/workers/journalist.rb
writefully-0.4.1	lib/writefully/workers/journalist.rb
writefully-0.4.0	lib/writefully/workers/journalist.rb