Module: Q::Methods::ThreadedInMemoryQueue

Includes:
Base
Defined in:
lib/q/methods/threaded_in_memory_queue.rb

Defined Under Namespace

Classes: QueueBuild, QueueConfig, QueueMethod, QueueTask

Class Method Summary collapse

Class Method Details

.included(base) ⇒ Object



2
3
4
5
6
7
8
# File 'lib/q/methods/threaded_in_memory_queue.rb', line 2

def self.included(base)
  require 'threaded_in_memory_queue'
  at_exit do
    ThreadedInMemoryQueue.stop  unless ::ThreadedInMemoryQueue.stopped?
  end
  super base
end