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