lib/fluffle/testing.rb in fluffle-0.1.0 vs lib/fluffle/testing.rb in fluffle-0.1.1

@@ -60,12 +60,10 @@
           $stderr.puts "No subscribers active for queue '#{queue_name}'"
           return nil
         end
 
         subscribers.each do |subscriber|
-          Thread.new do
-            subscriber.call(delivery_info, properties, payload)
-          end
+          subscriber.call(delivery_info, properties, payload)
         end
       end
 
       class Connection
         def initialize(server)