class Qpid::Proton::Container::ConnectionTask

Container driver applies options and adds container context to events

Public Class Methods

new(container, io, opts, server=false) click to toggle source
Calls superclass method Qpid::Proton::HandlerDriver.new
# File lib/core/container.rb, line 264
def initialize container, io, opts, server=false
  super io, opts[:handler]
  transport.set_server if server
  transport.apply opts
  connection.apply opts
  @work_queue = WorkQueue.new container
  connection.instance_variable_set(:@work_queue, @work_queue)
end

Public Instance Methods

dispatch() click to toggle source
Calls superclass method Qpid::Proton::HandlerDriver#dispatch
# File lib/core/container.rb, line 275
def dispatch              # Intercept dispatch to close work_queue
  super
  @work_queue.send(:close) if read_closed? && write_closed? 
end
next_tick() click to toggle source
Calls superclass method
# File lib/core/container.rb, line 272
def next_tick() earliest(super, @work_queue.send(:next_tick)); end
process(now) click to toggle source
Calls superclass method Qpid::Proton::HandlerDriver#process
# File lib/core/container.rb, line 273
def process(now) @work_queue.send(:process, now); super(); end