module QueueingRabbit::JobExtensions::Threaded

Public Class Methods

included(klass) click to toggle source
# File lib/queueing_rabbit/extensions/threaded.rb, line 27
def self.included(klass)
  klass.send(:include, Celluloid)
  klass.extend(ClassMethods)
end

Public Instance Methods

perform_and_terminate() click to toggle source
# File lib/queueing_rabbit/extensions/threaded.rb, line 32
def perform_and_terminate
  perform
  terminate
end