Module
AMQP::Client
In:
lib/amqp/client.rb
Methods
add_channel
channels
close
closing?
connect
connected?
connection_completed
connection_status
init_heartbeat
new
process_frame
receive_data
reconnect
send
tcp_connection_established?
unbind
Included Modules
EM::Deferrable
Public Class methods
connect
(arg = nil)
new
(opts = {})
Public Instance methods
add_channel
(mq)
channels
()
close
(&on_disconnect)
log 'send_data', data super
end
closing?
()
connected?
()
connection_completed
()
connection_status
(&blk)
init_heartbeat
()
process_frame
(frame)
receive_data
(data)
reconnect
(force = false)
send
(data, opts = {})
tcp_connection_established?
()
unbind
()
[Validate]