Module: MagicBus

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

Defined Under Namespace

Classes: Publisher, Subscriber

Constant Summary collapse

VERSION = 
'0.0.2'

Class Method Summary collapse

Class Method Details

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



5
6
7
8
9
 
# File 'lib/magicbus.rb', line 5

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