class Qpid::Proton::Container::ConnectionTask

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 258
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 269
def dispatch              # Intercept dispatch to close work_queue
  super
  @work_queue.close if read_closed? && write_closed?
end
next_tick() click to toggle source
Calls superclass method
# File lib/core/container.rb, line 266
def next_tick() earliest(super, @work_queue.next_tick); end
process(now) click to toggle source
Calls superclass method Qpid::Proton::HandlerDriver#process
# File lib/core/container.rb, line 267
def process(now) @work_queue.process(now); super(); end