class PikaQue::Connection

Attributes

connection[R]

Public Class Methods

create(opts = {}) click to toggle source
# File lib/pika_que/connection.rb, line 15
def self.create(opts = {})
  new(opts).tap{ |conn| conn.connect! }
end
new(opts = {}) click to toggle source
# File lib/pika_que/connection.rb, line 11
def initialize(opts = {})
  @opts = PikaQue.config.merge(opts)
end

Public Instance Methods

connect!() click to toggle source
# File lib/pika_que/connection.rb, line 19
def connect!
  @connection ||= Bunny.new(@opts[:amqp], :vhost => @opts[:vhost],
                          :heartbeat => @opts[:heartbeat],
                          :properties => @opts.fetch(:properties, {}),
                          :logger => PikaQue::logger).tap do |conn|
    conn.start
  end
end
connected?() click to toggle source
# File lib/pika_que/connection.rb, line 28
def connected?
  @connection && @connection.connected?
end
disconnect!() click to toggle source
# File lib/pika_que/connection.rb, line 32
def disconnect!
  @connection.close if @connection
  @connection = nil
end
ensure_connection() click to toggle source
# File lib/pika_que/connection.rb, line 37
def ensure_connection
  unless connected?
    @connection = nil
    connect!
  end
end