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