class Superbolt::Adapter::Bunny
Public Instance Methods
channel()
click to toggle source
# File lib/superbolt/adapter/bunny.rb, line 14 def channel @channel ||= socket.create_channel end
close()
click to toggle source
# File lib/superbolt/adapter/bunny.rb, line 18 def close response = channel.close @channel = nil response end
establish_socket()
click to toggle source
# File lib/superbolt/adapter/bunny.rb, line 8 def establish_socket socket = ::Bunny.new(config.connection_params) socket.start socket end
socket()
click to toggle source
# File lib/superbolt/adapter/bunny.rb, line 4 def socket Thread.current[:bunny_socket] ||= establish_socket end