Class: AmqpSpecHelper::DefaultExchange

Inherits:

Object

• Object
• AmqpSpecHelper::DefaultExchange

show all

Defined in:

lib/onapp/engine/spec/amqp_helper.rb

Instance Method Summary (collapse)

• - (DefaultExchange) initialize(channel) constructor

  A new instance of DefaultExchange.

• - (Object) messages
• - (Object) publish(msg, routing_key: nil, priority: nil)
• - (Object) send_message(qname, msgs)
• - (Object) send_messages

51
52
53

# File 'lib/onapp/engine/spec/amqp_helper.rb', line 51

def initialize(channel)
  @channel = channel
end

63
64
65

# File 'lib/onapp/engine/spec/amqp_helper.rb', line 63

def messages
  @messages ||= Hash.new { |h,k| h[k] = [] }
end

55
56
57

# File 'lib/onapp/engine/spec/amqp_helper.rb', line 55

def publish(msg, routing_key: nil, priority: nil)
  messages[routing_key.to_s] << msg
end

67
68
69
70

# File 'lib/onapp/engine/spec/amqp_helper.rb', line 67

def send_message(qname, msgs)
  msgs.each { |msg| @channel.queue(qname).publish(msg) }
  msgs.clear
end

59
60
61

# File 'lib/onapp/engine/spec/amqp_helper.rb', line 59

def send_messages
  messages.each(&method(:send_message))
end