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