Contents

# frozen_string_literal: true

require 'spec_helper'

class MsgrAutoAckConsumer < Msgr::Consumer
  self.auto_ack = true

  def index; end
end

class MsgrManualAckConsumer < Msgr::Consumer
  self.auto_ack = false

  def index; end
end

describe Msgr::Dispatcher do
  subject { dispatcher }

  let(:config) { {} }
  let(:args) { [config] }
  let(:dispatcher) { described_class.new(*args) }

  describe 'dispatch' do
    it 'acks messages automatically if auto_ack is enabled' do
      route_db = instance_double('Msgr::Route', consumer: 'MsgrAutoAckConsumer', action: :index)
      msg_db = instance_spy('Msgr::Message', route: route_db, acked?: false)

      dispatcher.dispatch(msg_db)

      expect(msg_db).to have_received(:ack)
      expect(msg_db).not_to have_received(:nack)
    end

    it 'does not ack messages if auto_ack is disabled' do
      route_db = instance_double('Msgr::Route', consumer: 'MsgrManualAckConsumer', action: :index)
      msg_db = instance_spy('Msgr::Message', route: route_db, acked?: false)

      dispatcher.dispatch(msg_db)

      expect(msg_db).not_to have_received(:ack)
      expect(msg_db).not_to have_received(:nack)
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
msgr-1.4.0	spec/unit/msgr/dispatcher_spec.rb
msgr-1.3.2	spec/unit/msgr/dispatcher_spec.rb
msgr-1.3.1	spec/unit/msgr/dispatcher_spec.rb
msgr-1.3.0	spec/unit/msgr/dispatcher_spec.rb