Class | Qpid::Proton::ConnectionDriver |
In: |
lib/core/connection_driver.rb
|
Parent: | Object |
Associate an AMQP {Connection} and {Transport} with an {IO}
Thread safety: The {ConnectionDriver} is not thread safe but separate {ConnectionDriver} instances can be processed concurrently. The {Container} handles multiple connections concurrently in multiple threads.
next_tick | [RW] | Time returned by the last call to {tick} |
Create a {Connection} and {Transport} associated with io @param io [IO] An {IO} or {IO}-like object that responds
to {IO#read_nonblock} and {IO#write_nonblock}
Disconnect both sides of the transport sending/waiting for AMQP close frames. See comments on {close_write}
Disconnect the read side of the transport, without waiting for an AMQP close frame. See comments on {close_write}
True if the ConnectionDriver has nothing left to do: both sides of the transport are closed and there are no events to dispatch.
Handle time-related work, for example idle-timeout events. May generate events for {event} and change {can_read?}, {can_write?}
@param [Time] now the current time, defaults to {Time#now}.
@return [Time] time of the next scheduled event, or nil if there are no scheduled events. If non-nil you must call {tick} again no later than this time.