Sha256: 08c756473685ec16e6fe0cf3ee14f1168770eeb9a292f88ff58e3e9f3f3532bc

Contents?: true

Size: 944 Bytes

Versions: 7

Compression:

Stored size: 944 Bytes

Contents

require 'spec_helper'

module RabbitFeed
  module TestingSupport
    describe TestingHelpers do
      describe 'consuming events' do
        accumulator = []

        let(:define_route) do
          EventRouting do
            accept_from('some_place') do
              event('some_event') do |event|
                accumulator << event
              end
            end
          end
        end

        let(:payload)  { {'stuff' => 'some_stuff'} }
        let(:metadata) { {'application' => 'some_place', 'name' => 'some_event'} }
        let(:event)    { Event.new metadata, payload }

        before { define_route }

        it 'should allow to send messages directly to the consumer' do
          rabbit_feed_consumer.consume_event event
          expect(accumulator.size).to eq(1)
          expect(accumulator[0].payload).to eq(payload)
          expect(accumulator[0].metadata).to eq(metadata)
        end
      end
    end
  end
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version Path
rabbit_feed-2.3.1 spec/lib/rabbit_feed/testing_support/testing_helper_spec.rb
rabbit_feed-2.3.0 spec/lib/rabbit_feed/testing_support/testing_helper_spec.rb
rabbit_feed-2.1.5 spec/lib/rabbit_feed/testing_support/testing_helper_spec.rb
rabbit_feed-2.1.2 spec/lib/rabbit_feed/testing_support/testing_helper_spec.rb
rabbit_feed-2.1.1 spec/lib/rabbit_feed/testing_support/testing_helper_spec.rb
rabbit_feed-2.1.0 spec/lib/rabbit_feed/testing_support/testing_helper_spec.rb
rabbit_feed-2.0.0 spec/lib/rabbit_feed/testing_support/testing_helper_spec.rb