Sha256: 2511005baeb453a03c272c04021f97213142c6210f694846c78da59f88fa4c92
Contents?: true
Size: 579 Bytes
Versions: 13
Compression:
Stored size: 579 Bytes
Contents
module Writefully module Workers class BaseWorker include Celluloid trap_exit :actor_died attr_reader :message def perform(message) @message = message self.__send__ message[:task] end def close_db_connection! ::ActiveRecord::Base.clear_active_connections! if defined?(::ActiveRecord) end def actor_died(actor, reason) Writefully.logger.error "#{reason.class} #{reason.message} #{reason.backtrace}" on_death(actor, reason) if self.respond_to?(:on_death) end end end end
Version data entries
13 entries across 13 versions & 1 rubygems