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

@@ -34,11 +34,11 @@
         thread.terminate
       end
 
       sleep(1) # Make sure the listener has started
 
-      Propono.publish(slow_topic, slow_text)
-      Propono.publish(topic, text)
+      Propono.publish(slow_topic, slow_text, async: false)
+      Propono.publish(topic, text, async: false)
       flunks << "Test Timeout" unless wait_for_thread(thread)
       flunk(flunks.join("\n")) unless flunks.empty?
     ensure
       # thread.terminate
     end