Skip to content

Commit

Permalink
Update tests
Browse files Browse the repository at this point in the history
  • Loading branch information
Michael Klishin committed Nov 29, 2012
1 parent 9815447 commit 52a1e36
Showing 1 changed file with 8 additions and 8 deletions.
16 changes: 8 additions & 8 deletions spec/higher_level_api/integration/queue_bind_spec.rb
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@
q = ch.queue("bunny.tests.queues.client-named#{rand}", :exclusive => true)
q.should_not be_server_named

q.bind("amq.fanout").should be_instance_of(AMQ::Protocol::Queue::BindOk)
q.bind("amq.fanout").should == q

ch.close
end
Expand All @@ -23,7 +23,7 @@
q.should_not be_server_named

q.bind("amq.fanout")
q.unbind("amq.fanout").should be_instance_of(AMQ::Protocol::Queue::UnbindOk)
q.unbind("amq.fanout").should == q

ch.close
end
Expand All @@ -33,7 +33,7 @@
q = ch.queue("bunny.tests.queues.client-named#{rand}", :exclusive => true)

x = ch.fanout("bunny.tests.exchanges.fanout#{rand}")
q.bind(x).should be_instance_of(AMQ::Protocol::Queue::BindOk)
q.bind(x).should == q

x.delete
ch.close
Expand All @@ -47,7 +47,7 @@
x = ch.fanout("bunny.tests.fanout", :auto_delete => true, :durable => false)

q.bind(x)
q.unbind(x).should be_instance_of(AMQ::Protocol::Queue::UnbindOk)
q.unbind(x).should == q

ch.close
end
Expand All @@ -67,7 +67,7 @@
q = ch.queue("", :exclusive => true)
q.should be_server_named

q.bind("amq.fanout").should be_instance_of(AMQ::Protocol::Queue::BindOk)
q.bind("amq.fanout").should == q

ch.close
end
Expand All @@ -78,7 +78,7 @@
q.should be_server_named

q.bind("amq.fanout")
q.unbind("amq.fanout").should be_instance_of(AMQ::Protocol::Queue::UnbindOk)
q.unbind("amq.fanout").should == q

ch.close
end
Expand All @@ -88,7 +88,7 @@
q = ch.queue("", :exclusive => true)

x = ch.fanout("bunny.tests.exchanges.fanout#{rand}")
q.bind(x).should be_instance_of(AMQ::Protocol::Queue::BindOk)
q.bind(x).should == q

x.delete
ch.close
Expand All @@ -101,7 +101,7 @@
name = "bunny.tests.exchanges.fanout#{rand}"
x = ch.fanout(name)
q.bind(x)
q.unbind(name).should be_instance_of(AMQ::Protocol::Queue::UnbindOk)
q.unbind(name).should == q

x.delete
ch.close
Expand Down

0 comments on commit 52a1e36

Please sign in to comment.