Skip to content
Browse files

After ruby-amqp/amq-client@81b089d, this example is no longer relevant

  • Loading branch information...
1 parent 99b1f30 commit 8f9bbf73810cb8e665d938073d10a2145a17614f @michaelklishin michaelklishin committed Jan 19, 2012
Showing with 0 additions and 33 deletions.
  1. +0 −33 spec/integration/extensions/rabbitmq/publisher_confirmations_spec.rb
View
33 spec/integration/extensions/rabbitmq/publisher_confirmations_spec.rb
@@ -83,39 +83,6 @@
end
end
- it 'should call after_publish callback' do
- events = Array.new
-
- channel3 = AMQP::Channel.new
- exchange = channel3.fanout("amqpgem.tests.fanout0", :auto_delete => true)
-
- channel3.confirm_select
-
- #TODO make after_publish a real callback to avoid these meta gymnastics
- after_publish = lambda do |*args|
- events << :after_publish
- end
-
- if RUBY_VERSION < '1.9'
- class AMQP::Channel
- def singleton_class
- class << self
- self
- end
- end
- end
- end
-
- channel3.singleton_class.send(:define_method, :after_publish, &after_publish)
-
- EventMachine.add_timer(0.5) do
- exchange.publish("Hi")
- end
-
- done(2.0) do
- events.should include(:after_publish)
- end
- end
context "when messages are transient" do
context "and routable" do

0 comments on commit 8f9bbf7

Please sign in to comment.
Something went wrong with that request. Please try again.