Sha256: e40a9406ea7b3bab747ead57809a2d4095c5aead3564c7024253e7879b26ae0a

Contents?: true

Size: 357 Bytes

Versions: 6

Compression:

Stored size: 357 Bytes

Contents

module Legion
  module Transport
    class Queue
      def initialize(**opts)
      end

      def queue_name
        'test_queue'
      end

      def acknowledge(delivery_tag)
        true
      end

      def reject(delivery_tag, requeue: false, **)
        true
      end

      def queue_options
        Concurrent::Hash.new
      end
    end
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version Path
legionio-1.2.1 lib/legion/cli/lex/templates/queue_helper.erb
legionio-1.2.0 lib/legion/cli/lex/templates/queue_helper.erb
legionio-0.4.3 lib/legion/cli/lex/templates/queue_helper.erb
legionio-0.4.2 lib/legion/cli/lex/templates/queue_helper.erb
legionio-0.4.1 lib/legion/cli/lex/templates/queue_helper.erb
legionio-0.4.0 lib/legion/cli/lex/templates/queue_helper.erb