Contents

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
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
legion-transport-1.0.0	lib/legion/transport/consumer.rb