Contents

require 'songkick_queue'
require 'songkick_queue/producer'

module SongkickQueue
  RSpec.describe Producer do
    describe "#publish" do
      it "should publish the message to the exchange as JSON, with the correct routing key" do
        producer = Producer.new

        exchange = double(:exchange, publish: :published)
        client = instance_double(Client, default_exchange: exchange)
        allow(producer).to receive(:client) { client }

        logger = double(:logger, info: true)
        allow(producer).to receive(:logger) { logger }

        expect(exchange).to receive(:publish)
          .with('{"message_id":"92c583bdc248","produced_at":"2015-03-30T15:41:55Z",' +
            '"payload":{"example":"message","value":true}}', routing_key: 'queue_name')

        expect(logger).to receive(:info)
          .with("Published message 92c583bdc248 to 'queue_name' at 2015-03-30T15:41:55Z")

        producer.publish(:queue_name, { example: 'message', value: true },
          message_id: '92c583bdc248', produced_at: '2015-03-30T15:41:55Z')
      end

      it "should retry when publishing fails" do
        producer = Producer.new

        exchange = double(:exchange, publish: :published)
        allow(exchange).to receive(:publish) { raise Bunny::ConnectionClosedError, 'test' }
        client = instance_double(Client, default_exchange: exchange)
        allow(producer).to receive(:client) { client }

        logger = double(:logger, info: true)
        allow(producer).to receive(:logger) { logger }

        allow(producer).to receive(:wait_for_bunny_session_to_reconnect) { true }

        config = double(:config, max_reconnect_attempts: 2)
        allow(producer).to receive(:config) { config }

        expect { producer.publish(:queue_name, { example: 'message', value: true }) }.to(
          raise_error(TooManyReconnectAttemptsError, 'Attempted to reconnect more than 2 times'))

        expect(producer.reconnect_attempts).to eq 3
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
songkick_queue-1.1.0	spec/songkick_queue/producer_spec.rb
songkick_queue-1.0.0	spec/songkick_queue/producer_spec.rb
songkick_queue-0.6.0	spec/songkick_queue/producer_spec.rb
songkick_queue-0.5.0	spec/songkick_queue/producer_spec.rb