Class: Lagomorph::QueueBuilder

Inherits:

Struct

• Object
• Struct
• Lagomorph::QueueBuilder

Defined in:

lib/lagomorph/queue_builder.rb

Instance Attribute Summary

• #channel ⇒ Object

  Returns the value of attribute channel.

Instance Method Summary

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

  Build a reply queue.

Instance Attribute Details

#channel ⇒ Object

Returns the value of attribute channel

Returns:

• (Object) —

  the current value of channel

# File 'lib/lagomorph/queue_builder.rb', line 5

def channel
  @channel
end

Instance Method Details

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

# File 'lib/lagomorph/queue_builder.rb', line 6

def queue(name, opts={})
  QueueAdapter.new(channel.queue(name, opts))
end

#reply_queue ⇒ Object

Build a reply queue

# File 'lib/lagomorph/queue_builder.rb', line 11

def reply_queue
  queue('', exclusive: true)
end