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

@@ -8,9 +8,10 @@
       flunks = []
       message_received = false
 
       Propono.config.udp_port = 20001
 
+      Propono.drain_queue(topic)
       Propono.subscribe_by_queue(topic)
 
       sqs_thread = Thread.new do
         begin
           Propono.listen_to_queue(topic) do |message, context|