Contents

# -*- encoding : utf-8 -*-
require 'spec_helper'

module Untied
  module Publisher
    module AMQP
      describe Producer do
        context "configuration" do
          it "should use service name configured" do
            mock_reactor_and_amqp do |c|
              Producer.new.service_name.should == 'core'
            end
          end
        end

        it "should initilize producer" do
          mock_reactor_and_amqp do |c|
            Producer.new.should be_a Producer
          end
        end

        it "should raise RuntimeError when trying to run without connection" do
          expect {
            Producer.new(:deliver_messages => true)
          }.to raise_error
        end

        it "should raise RuntimeError if EM is not running" do
          mock_reactor_and_amqp do |c|
            EM.stub("reactor_running?" => false)
            expect {
              Producer.new(:channel => c, :deliver_messages => true)
            }.to raise_error
          end
        end

        context "#publish" do
          let(:event) do
            Event.new(:name => "create", :payload => { :foo => 'bar' }, :origin => :core)
          end

          it "should call Channel#publish" do
            mock_reactor_and_amqp do |channel|
              producer = Producer.new(:channel => channel, :deliver_messages => true)
              producer.should_receive(:safe_publish).with(event)
              producer.publish(event)
            end
          end
        end

        def mock_reactor_and_amqp
          # Do nothing when calling start
          Untied.stub(:start).and_return(nil)
          # Simulate reactor running
          EM.stub(:reactor_running?).and_return(true)

          exchange = double('Exchange')
          channel = double('Channel')
          channel.stub(:topic).and_return(exchange)

          yield(channel)
        end
      end
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
untied-publisher-0.0.7.pre3	spec/amqp/amqp_producer_spec.rb
untied-publisher-0.0.7.pre2	spec/amqp/amqp_producer_spec.rb
untied-publisher-0.0.7.pre1	spec/amqp/amqp_producer_spec.rb
untied-publisher-0.0.7.pre	spec/amqp/amqp_producer_spec.rb
untied-publisher-0.0.6	spec/amqp/amqp_producer_spec.rb