Class: Legion::Transport::Consumer

Inherits:
Legion::Transport::CONNECTOR::Consumer
  • Object
show all
Includes:
Common
Defined in:
lib/legion/transport/consumer.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods included from Common

#channel, #channel_open?, #close, #close!, #deep_merge, #generate_consumer_tag, #open_channel, #options_builder

Constructor Details

#initialize(queue:, no_ack: false, exclusive: false, consumer_tag: generate_consumer_tag, **opts) ⇒ Consumer

Returns a new instance of Consumer.



7
8
9
10
 
# File 'lib/legion/transport/consumer.rb', line 7

def initialize(queue:, no_ack: false, exclusive: false, consumer_tag: generate_consumer_tag, **opts)
  @consumer_tag = consumer_tag
  super(channel, queue, consumer_tag, no_ack, exclusive, opts)
end

Instance Attribute Details

#consumer_tag ⇒ Object (readonly)

Returns the value of attribute consumer_tag.



5
6
7
 
# File 'lib/legion/transport/consumer.rb', line 5

def consumer_tag
  @consumer_tag
end