class PikaQ::Connection

Attributes

channel[R]
rabbitmq_url[R]
session[R]

Public Class Methods

new(rabbitmq_url = ENV['RABBITMQ_URL'], options = { read_timeout: 10, heartbeat: 10 }) click to toggle source
# File lib/pika_q/connection.rb, line 7
def initialize(rabbitmq_url = ENV['RABBITMQ_URL'], options = { read_timeout: 10, heartbeat: 10 })
  @session = Bunny.new(rabbitmq_url, options)
  @session.start
  @channel = @session.create_channel
end