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