Method: MmMq::Publishable#connect

Defined in:
lib/mm_mq/publishable.rb

#connect(options = {}, &block) ⇒ Object

MQ.startを実行します。



32
33
34
35
36
37
38
39
40
41
42
43
 
# File 'lib/mm_mq/publishable.rb', line 32

def connect(options = {}, &block)
  conn = nil
  EM.run do
    if conn_opts = HashExt.symbolize_keys(config[:connections] || config['connections'])
      conn = AMQP.vstart(options.update(conn_opts))
    else
      conn = AMQP.start(options.update(HashExt.symbolize_keys(config[:connection] || config['connection']) || {}))
    end
    channel(conn)
    block.call if block
  end
end