Contents

require 'spec_helper'

class TestConsumer < Msgr::Consumer
  def index
    puts "<<< #{payload}"
  end
end

describe Msgr do
  before do
    Msgr.logger = nil;
    Msgr.logger.level = Logger::Severity::DEBUG if Msgr.logger
  end

  let(:client) { Msgr::Client.new size: 1, prefix: SecureRandom.hex(32) }

  before do
    client.routes.configure do
      route '#', to: 'test#index'
    end

    client.start
  end

  after do
    client.stop timeout: 10, delete: true, wait_empty: 10
  end

  it 'should dispatch published methods to consumer' do
    expect_any_instance_of(TestConsumer).to receive(:index).within(10).seconds.and_call_original

    client.publish 'Payload', to: 'routing.key'

    sleep 10
  end

  describe '.after_load' do
    before { allow_any_instance_of(Msgr::Client).to receive(:launch) }

    it 'should yield the given block when Msgr.start is called' do
      expect { |cb| Msgr.after_load &cb; Msgr.start }.to yield_with_args
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
msgr-0.4.1	spec/msgr/msgr_spec.rb
msgr-0.4.0	spec/msgr/msgr_spec.rb