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

12 entries across 12 versions & 2 rubygems

Version	Path
legion-transport-1.2.0	lib/legion/transport/consumer.rb
legion-transport-1.1.9	lib/legion/transport/consumer.rb
legion-transport-1.1.8	lib/legion/transport/consumer.rb
legion-transport-1.1.6	lib/legion/transport/consumer.rb
legion-transport-1.1.5	lib/legion/transport/consumer.rb
legion-transport-java-1.1.4	lib/legion/transport/consumer.rb
legion-transport-1.1.4	lib/legion/transport/consumer.rb
legion-transport-java-1.1.3	lib/legion/transport/consumer.rb
legion-transport-1.1.3	lib/legion/transport/consumer.rb
legion-transport-1.1.2	lib/legion/transport/consumer.rb
legion-transport-1.1.1	lib/legion/transport/consumer.rb
legion-transport-1.1.0	lib/legion/transport/consumer.rb