Sha256: 75836b9daa7615cf2f149fd37b21e76dbf812e58d1649e88f1c638da7521e36f

Contents?: true

Size: 1.99 KB

Versions: 4

Compression:

Stored size: 1.99 KB

Contents

# encoding: utf-8

# bunny_spec.rb

# Assumes that target message broker/server has a user called 'guest' with a password 'guest'
# and that it is running on 'localhost'.

# If this is not the case, please change the 'Bunny.new' call below to include
# the relevant arguments e.g. @b = Bunny.new(:user => 'john', :pass => 'doe', :host => 'foobar')

require File.expand_path(File.join(File.dirname(__FILE__), %w[.. .. lib bunny]))

describe Bunny do

  before(:each) do
    @b = Bunny.new
    @b.start
  end

  after(:each) do
    begin
      @b.stop
    rescue Exception
    ensure
      @b = nil
    end
  end

  it "should connect to an AMQP server" do
    @b.status.should == :connected
  end

  it "should be able to create and open a new channel" do
    c = @b.create_channel
    c.number.should == 2
    c.should be_an_instance_of(Bunny::Channel)
    @b.channels.size.should == 3
    c.open.should == :open_ok
    @b.channel.number.should == 2
  end

  it "should be able to switch between channels" do
    @b.channel.number.should == 1
    @b.switch_channel(0)
    @b.channel.number.should == 0
  end

  it "should raise an error if trying to switch to a non-existent channel" do
    lambda { @b.switch_channel(5)}.should raise_error(RuntimeError)
  end

  it "should be able to create an exchange" do
    exch = @b.exchange('test_exchange')
    exch.should be_an_instance_of(Bunny::Exchange)
    exch.name.should == 'test_exchange'
    @b.exchanges.has_key?('test_exchange').should be(true)
  end

  it "should be able to create a queue" do
    q = @b.queue('test1')
    q.should be_an_instance_of(Bunny::Queue)
    q.name.should == 'test1'
    @b.queues.has_key?('test1').should be(true)
  end

  # Current RabbitMQ has not implemented some functionality
  it "should raise an error if setting of QoS fails" do
    lambda { @b.qos(:global => true) }.should raise_error(Bunny::ForcedConnectionCloseError)
    @b.status.should == :not_connected
  end

  it "should be able to set QoS" do
    @b.qos.should == :qos_ok
  end

end

Version data entries

4 entries across 4 versions & 2 rubygems

Version Path
sparqcode_bunny-0.0.2 spec/spec_08/bunny_spec.rb
bunny-0.7.9 spec/spec_08/bunny_spec.rb
sparqcode_bunny-0.0.1 spec/spec_08/bunny_spec.rb
bunny-0.7.8 spec/spec_08/bunny_spec.rb