class Rmsg::Rabbit

Attributes

channel[R]

@return [Bunny::Channel]

connection[R]

@return [Bunny::Connection]

Public Class Methods

new() click to toggle source

On creation holds references to RabbitMQ via a Bunny connection and a Bunny channel.

# File lib/rmsg/rabbit.rb, line 10
def initialize
  @connection = Bunny.new
  @connection.start
  @channel = @connection.create_channel
end

Public Instance Methods

close() click to toggle source

Close the channel and the connection to RabbitMQ.

# File lib/rmsg/rabbit.rb, line 17
def close
  @channel.close
  @connection.close
end