Class: AmqpSpecHelper::FanoutExchange

Inherits:
DefaultExchange show all
Defined in:
lib/onapp/engine/spec/amqp_helper.rb

Instance Method Summary (collapse)

Methods inherited from DefaultExchange

#initialize, #messages, #publish, #send_message

Constructor Details

This class inherits a constructor from AmqpSpecHelper::DefaultExchange

Instance Method Details

- (Object) bound_queues 



74
75
76
 
# File 'lib/onapp/engine/spec/amqp_helper.rb', line 74

def bound_queues
  @bound_queues ||= []
end

- (Object) send_messages 



78
79
80
81
82
83
84
85
 
# File 'lib/onapp/engine/spec/amqp_helper.rb', line 78

def send_messages
  messages.values.flatten.each do |msg|
    bound_queues.each do |q|
      q.publish(msg)
    end
  end
  super
end