module Emque::Consuming::Actor
Public Class Methods
included(descendant)
click to toggle source
# File lib/emque/consuming/actor.rb, line 4 def self.included(descendant) descendant.class_eval do include Celluloid include Emque::Consuming::Helpers attr_accessor :shutdown private :shutdown= private :shutdown end end
Public Instance Methods
stop(&block)
click to toggle source
# File lib/emque/consuming/actor.rb, line 14 def stop(&block) self.shutdown = true block.call if block_given? terminate end