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

- old
+ new

@@ -1,12 +1,12 @@ require File.expand_path('../integration_test', __FILE__) module Propono class SlowQueueTest < IntegrationTest def test_slow_messages_are_received - topic = "slow-test-topic" - slow_topic = "slow-test-topic-slow" + topic = "propono-tests-slow-queue-topic" + slow_topic = "propono-tests-slow-queue-topic-slow" text = "This is my message #{DateTime.now} #{rand()}" slow_text = "This is my slow message #{DateTime.now} #{rand()}" flunks = [] message_received = false slow_message_received = false @@ -40,8 +40,8 @@ Propono.publish(topic, text) flunks << "Test Timeout" unless wait_for_thread(thread) flunk(flunks.join("\n")) unless flunks.empty? ensure # thread.terminate - end + end end end