Method: Qpid::Proton::WorkQueue#initialize

Defined in:
lib/core/work_queue.rb

#initialize(container) ⇒ WorkQueue

Returns a new instance of WorkQueue.

API:

  • qpid



71
72
73
74
75
76
 
# File 'lib/core/work_queue.rb', line 71

def initialize(container)
  @lock = Mutex.new
  @schedule = Schedule.new
  @container = container
  @closed = nil
end