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