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