class ActivePubsub::Connection

Attributes

channel[RW]
connection[RW]

Public Class Methods

new(options = {}) click to toggle source
# File lib/active_pubsub/connection.rb, line 7
def initialize(options = {})
  @connection = ::Bunny.new(::ActivePubsub.config.try(:address) || ENV["RABBITMQ_URL"])
  @connection.start
  @channel = connection.create_channel
end

Public Instance Methods

__getobj__() click to toggle source
# File lib/active_pubsub/connection.rb, line 13
def __getobj__
  @connection
end