Module: MagicBus

Defined in:
lib/magicbus.rb,
lib/magicbus/version.rb

Defined Under Namespace

Classes: Publisher, Subscriber

Constant Summary collapse

VERSION = 
'0.1.1'

Class Attribute Summary collapse

Class Method Summary collapse

Class Attribute Details

.connection ⇒ Object

Returns the value of attribute connection.



9
10
11
 
# File 'lib/magicbus.rb', line 9

def connection
  @connection
end

Class Method Details

.connect(params = { host: '127.0.0.1' }) ⇒ Object 



12
13
14
15
16
 
# File 'lib/magicbus.rb', line 12

def self.connect(params = { host: '127.0.0.1' })
  EM.next_tick do
    self.connection = AMQP.connect(*params)
  end
end