class Superbolt::Adapter::AMQP

Public Instance Methods

channel() click to toggle source
# File lib/superbolt/adapter/amqp.rb, line 8
def channel
  @channel ||= ::AMQP::Channel.new(socket)
end
close(&block) click to toggle source
# File lib/superbolt/adapter/amqp.rb, line 12
def close(&block)
  socket.close(&block)
end
socket() click to toggle source
# File lib/superbolt/adapter/amqp.rb, line 4
def socket
  @socket ||= ::AMQP.connect(config.connection_params)
end