Sha256: 715322b73f0b6d759dd274df2155e5e135bf49e3b80c6d645d5c47c380aacd28

Contents?: true

Size: 294 Bytes

Versions: 8

Compression:

Stored size: 294 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

8 entries across 8 versions & 1 rubygems

Version Path
basquiat-1.6.0 lib/basquiat/adapters/rabbitmq/requeue_strategies/auto_acknowledge.rb
basquiat-1.5.2 lib/basquiat/adapters/rabbitmq/requeue_strategies/auto_acknowledge.rb
basquiat-1.5.1 lib/basquiat/adapters/rabbitmq/requeue_strategies/auto_acknowledge.rb
basquiat-1.5.0 lib/basquiat/adapters/rabbitmq/requeue_strategies/auto_acknowledge.rb
basquiat-1.4.0 lib/basquiat/adapters/rabbitmq/requeue_strategies/auto_acknowledge.rb
basquiat-1.3.6 lib/basquiat/adapters/rabbitmq/requeue_strategies/auto_acknowledge.rb
basquiat-1.3.5 lib/basquiat/adapters/rabbitmq/requeue_strategies/auto_acknowledge.rb
basquiat-1.3.4 lib/basquiat/adapters/rabbitmq/requeue_strategies/auto_acknowledge.rb