Class: MQ

Inherits:
Object
  • Object
show all
Defined in:
lib/moqueue/overloads.rb

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(*args) ⇒ MQ

Returns a new instance of MQ.



20
21
 
# File 'lib/moqueue/overloads.rb', line 20

def initialize(*args)
end

Class Method Details

.direct(name, opts = {}) ⇒ Object 



10
11
12
 
# File 'lib/moqueue/overloads.rb', line 10

def direct(name, opts={})
  Moqueue::MockExchange.new(opts.merge(:direct=>name))
end

.fanout(name, opts = {}) ⇒ Object 



14
15
16
 
# File 'lib/moqueue/overloads.rb', line 14

def fanout(name, opts={})
  Moqueue::MockExchange.new(opts.merge(:fanout=>name))
end

.queue(name) ⇒ Object 



6
7
8
 
# File 'lib/moqueue/overloads.rb', line 6

def queue(name)
  Moqueue::MockQueue.new(name)
end

Instance Method Details

#direct(name, opts = {}) ⇒ Object 



23
24
25
 
# File 'lib/moqueue/overloads.rb', line 23

def direct(name, opts = {})
  Moqueue::MockExchange.new(opts.merge(:direct => name))
end

#fanout(name, opts = {}) ⇒ Object 



27
28
29
 
# File 'lib/moqueue/overloads.rb', line 27

def fanout(name, opts = {})
  Moqueue::MockExchange.new(opts.merge(:fanout => name))
end

#queue(name, opts = {}) ⇒ Object 



31
32
33
 
# File 'lib/moqueue/overloads.rb', line 31

def queue(name, opts = {})
  Moqueue::MockQueue.new(name)
end

#topic(topic_name) ⇒ Object 



35
36
37
 
# File 'lib/moqueue/overloads.rb', line 35

def topic(topic_name)
  Moqueue::MockExchange.new(:topic=>topic_name)
end