Module: EQ::Queueing

Defined in:

lib/eq-queueing.rb,
lib/eq-queueing/queue.rb,
lib/eq-queueing/backends.rb

Defined Under Namespace

Modules: Backends Classes: Queue

Constant Summary

EQ_QUEUE =

:_eq_queueing

Class Method Summary

• .boot ⇒ Object
• .queue ⇒ Object
• .shutdown ⇒ Object

Class Method Details

.boot ⇒ Object

# File 'lib/eq-queueing.rb', line 10

def boot
  EQ::Queueing::Queue.supervise_as EQ_QUEUE, EQ::Queueing::Backends.init(EQ.config)
end

.queue ⇒ Object

# File 'lib/eq-queueing.rb', line 18

def queue
  Celluloid::Actor[EQ_QUEUE]
end

.shutdown ⇒ Object

# File 'lib/eq-queueing.rb', line 14

def shutdown
  queue.terminate! if queue
end