module Fluffle::Connectable

Public Class Methods

included(klass) click to toggle source
# File lib/fluffle/connectable.rb, line 3
def self.included(klass)
  klass.class_eval do
    attr_reader :connection
  end
end

Public Instance Methods

connect(*args) click to toggle source
# File lib/fluffle/connectable.rb, line 9
def connect(*args)
  self.stop if self.connected?

  @connection =
    if args.first.is_a? Bunny::Session
      args.first
    else
      Bunny.new *args
    end

  @connection.start
end
connected?() click to toggle source
# File lib/fluffle/connectable.rb, line 22
def connected?
  @connection && @connection.connected?
end