Sha256: 9d1108aad731e32e19f46cdc7d2820218badc54765d0b0c524183a82914de639

Contents?: true

Size: 603 Bytes

Versions: 4

Compression:

Stored size: 603 Bytes

Contents

require 'spec_helper'

describe Freddy::Consumer do
  let(:freddy) { Freddy.build(logger, config) }

  let(:destination) { random_destination }
  let(:payload)     { {pay: 'load'} }

  let(:consumer) { freddy.consumer }

  after { freddy.close }

  it 'raises exception when no consumer is provided' do
    expect { consumer.consume destination }.to raise_error described_class::EmptyConsumer
  end

  it "doesn't call passed block without any messages" do
    consumer.consume destination do
      @message_received = true
    end
    default_sleep

    expect(@message_received).to be_falsy
  end
end

Version data entries

4 entries across 4 versions & 2 rubygems

Version Path
freddy-0.4.6 spec/freddy/consumer_spec.rb
freddy-0.4.4 spec/freddy/consumer_spec.rb
freddy-jruby-0.4.3 spec/freddy/consumer_spec.rb
freddy-0.4.3 spec/freddy/consumer_spec.rb