lib/legion/transport/consumer.rb in legion-transport-1.0.0 vs lib/legion/transport/consumer.rb in legion-transport-1.1.0
- old
+ new
@@ -1,9 +1,10 @@
module Legion
module Transport
class Consumer < Legion::Transport::CONNECTOR::Consumer
include Legion::Transport::Common
attr_reader :consumer_tag
+
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
end