test/integration/slow_queue_test.rb in propono-1.3.0 vs test/integration/slow_queue_test.rb in propono-1.4.0

@@ -9,9 +9,11 @@
       slow_text = "This is my slow message #{DateTime.now} #{rand()}"
       flunks = []
       message_received = false
       slow_message_received = false
 
+      Propono.drain_queue(slow_topic)
+      Propono.drain_queue(topic)
       Propono.subscribe_by_queue(topic)
 
       thread = Thread.new do
         begin
           Propono.listen_to_queue(topic) do |message, context|