Sha256: 85747f6509b68bf91dc9c32d61132b36a32202f73075fd295f833eecbd01e676

Contents?: true

Size: 293 Bytes

Versions: 3

Compression:

Stored size: 293 Bytes

Contents

# frozen_string_literal: true
module Basquiat
  module Adapters
    class RabbitMq
      class AutoAcknowledge < BaseStrategy
        def self.session_options
          { consumer: { manual_ack: false } }
        end

        def run(*)
          yield
        end
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version Path
basquiat-1.3.2 lib/basquiat/adapters/rabbitmq/requeue_strategies/auto_acknowledge.rb
basquiat-1.3.1 lib/basquiat/adapters/rabbitmq/requeue_strategies/auto_acknowledge.rb
basquiat-1.3.0 lib/basquiat/adapters/rabbitmq/requeue_strategies/auto_acknowledge.rb