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